| org.apache.servicemix.common.endpoints.ConsumerEndpoint org.apache.servicemix.jms.endpoints.AbstractConsumerEndpoint
All known Subclasses: org.apache.servicemix.jms.endpoints.JmsConsumerEndpoint, org.apache.servicemix.jms.endpoints.JmsJcaConsumerEndpoint,
Method Summary | |
public ConnectionFactory | getConnectionFactory() | public DestinationChooser | getDestinationChooser() | public DestinationResolver | getDestinationResolver() | public String | getLocationURI() | public JmsConsumerMarshaler | getMarshaler() | public int | getReplyDeliveryMode() | public Destination | getReplyDestination() | protected Destination | getReplyDestination(MessageExchange exchange, Object message, Session session, JmsContext context) | public String | getReplyDestinationName() | public int | getReplyPriority() | public Map<String, Object> | getReplyProperties() | public long | getReplyTimeToLive() | public Store | getStore() | public StoreFactory | getStoreFactory() | public Boolean | getUseMessageIdInResponse() | protected void | handleException(MessageExchange exchange, Exception error, Session session, JmsContext context) | public boolean | isPubSubDomain() | public boolean | isReplyExplicitQosEnabled() | public boolean | isStateless() | public boolean | isSynchronous() | protected void | onMessage(Message jmsMessage, Session session) | public void | process(MessageExchange exchange) | protected void | processExchange(MessageExchange exchange, Session session, JmsContext context) | protected void | send(Message msg, Session session, Destination dest) | protected void | sendError(MessageExchange exchange, Exception error, Session session, JmsContext context) | public void | setConnectionFactory(ConnectionFactory connectionFactory) | protected void | setCorrelationId(Message query, Message reply) | public void | setDestinationChooser(DestinationChooser destinationChooser) | public void | setDestinationResolver(DestinationResolver destinationResolver) | public void | setMarshaler(JmsConsumerMarshaler marshaler) | public void | setPubSubDomain(boolean pubSubDomain) | public void | setReplyDeliveryMode(int replyDeliveryMode) | public void | setReplyDestination(Destination replyDestination) | public void | setReplyDestinationName(String replyDestinationName) | public void | setReplyExplicitQosEnabled(boolean replyExplicitQosEnabled) | public void | setReplyPriority(int replyPriority) | public void | setReplyProperties(Map<String, Object> replyProperties) | public void | setReplyTimeToLive(long replyTimeToLive) | public void | setStateless(boolean stateless) | public void | setStore(Store store) | public void | setStoreFactory(StoreFactory storeFactory) | public void | setSynchronous(boolean synchronous) | public void | setUseMessageIdInResponse(Boolean useMessageIdInResponse) | public synchronized void | start() | public synchronized void | stop() | protected boolean | treatExceptionAsFault(Exception error) |
PROP_JMS_CONTEXT | final protected static String PROP_JMS_CONTEXT(Code) | | |
AbstractConsumerEndpoint | public AbstractConsumerEndpoint()(Code) | | |
getConnectionFactory | public ConnectionFactory getConnectionFactory()(Code) | | the connectionFactory |
getDestinationResolver | public DestinationResolver getDestinationResolver()(Code) | | the destinationResolver |
getReplyDeliveryMode | public int getReplyDeliveryMode()(Code) | | the replyDeliveryMode |
getReplyDestination | public Destination getReplyDestination()(Code) | | the replyDestination |
getReplyDestination | protected Destination getReplyDestination(MessageExchange exchange, Object message, Session session, JmsContext context) throws JMSException(Code) | | |
getReplyDestinationName | public String getReplyDestinationName()(Code) | | the replyDestinationName |
getReplyPriority | public int getReplyPriority()(Code) | | the replyPriority |
getReplyTimeToLive | public long getReplyTimeToLive()(Code) | | the replyTimeToLive |
getUseMessageIdInResponse | public Boolean getUseMessageIdInResponse()(Code) | | the useMessageIdInResponse |
isPubSubDomain | public boolean isPubSubDomain()(Code) | | the pubSubDomain |
isReplyExplicitQosEnabled | public boolean isReplyExplicitQosEnabled()(Code) | | the replyExplicitQosEnabled |
isStateless | public boolean isStateless()(Code) | | |
isSynchronous | public boolean isSynchronous()(Code) | | the synchronous |
onMessage | protected void onMessage(Message jmsMessage, Session session) throws JMSException(Code) | | |
send | protected void send(Message msg, Session session, Destination dest) throws JMSException(Code) | | |
setConnectionFactory | public void setConnectionFactory(ConnectionFactory connectionFactory)(Code) | | Parameters: connectionFactory - the connectionFactory to set |
setCorrelationId | protected void setCorrelationId(Message query, Message reply) throws Exception(Code) | | |
setDestinationChooser | public void setDestinationChooser(DestinationChooser destinationChooser)(Code) | | Parameters: destinationChooser - the destinationChooser to set |
setDestinationResolver | public void setDestinationResolver(DestinationResolver destinationResolver)(Code) | | Parameters: destinationResolver - the destinationResolver to set |
setPubSubDomain | public void setPubSubDomain(boolean pubSubDomain)(Code) | | Parameters: pubSubDomain - the pubSubDomain to set |
setReplyDeliveryMode | public void setReplyDeliveryMode(int replyDeliveryMode)(Code) | | Parameters: replyDeliveryMode - the replyDeliveryMode to set |
setReplyDestination | public void setReplyDestination(Destination replyDestination)(Code) | | Parameters: replyDestination - the replyDestination to set |
setReplyDestinationName | public void setReplyDestinationName(String replyDestinationName)(Code) | | Parameters: replyDestinationName - the replyDestinationName to set |
setReplyExplicitQosEnabled | public void setReplyExplicitQosEnabled(boolean replyExplicitQosEnabled)(Code) | | Parameters: replyExplicitQosEnabled - the replyExplicitQosEnabled to set |
setReplyPriority | public void setReplyPriority(int replyPriority)(Code) | | Parameters: replyPriority - the replyPriority to set |
setReplyProperties | public void setReplyProperties(Map<String, Object> replyProperties)(Code) | | Parameters: replyProperties - the replyProperties to set |
setReplyTimeToLive | public void setReplyTimeToLive(long replyTimeToLive)(Code) | | Parameters: replyTimeToLive - the replyTimeToLive to set |
setStateless | public void setStateless(boolean stateless)(Code) | | |
setSynchronous | public void setSynchronous(boolean synchronous)(Code) | | Parameters: synchronous - the synchronous to set |
setUseMessageIdInResponse | public void setUseMessageIdInResponse(Boolean useMessageIdInResponse)(Code) | | Parameters: useMessageIdInResponse - the useMessageIdInResponse to set |
treatExceptionAsFault | protected boolean treatExceptionAsFault(Exception error)(Code) | | |
|
|