| dalma.endpoints.jms.JMSEndPoint
| JMSEndPoint | | public class JMSEndPoint extends MultiplexedEndPoint implements MessageListener(Code) | | EndPoint that connects to two JMS queues.
author:
Kohsuke Kawaguchi |
| Constructor Summary | |
| public | JMSEndPoint(String name, Session session, Destination out, Destination in)
Creates a new
JMSEndPoint .
Parameters:
name - name that uniquely identifies endpoints inside an Engine.must not be null.
Parameters:
session - JMS messages are sent/received through this session. |
| JMSEndPoint | | public JMSEndPoint(String name, Session session, Destination out, Destination in) throws JMSException(Code) | | Creates a new
JMSEndPoint .
Parameters:
name - name that uniquely identifies endpoints inside an Engine.must not be null.
Parameters:
session - JMS messages are sent/received through this session. must not be null.
Parameters:
out - The default Destination where out-going messages are sent to.can be null, in which case every out-going message must have aDestination set (such as when every outgoing message is a reply.)
Parameters:
in - The Destination where in-coming messages are picked up.must not be null. |
| createMessage | | public T createMessage(Class<T> type)(Code) | | Creates a new blank
Message of the specified type.
Parameters:
type - one of 5 Message-derived types defined in JMS. |
| createReplyMessage | | public T createReplyMessage(Class<T> type, Message in) throws JMSException(Code) | | Creates a reply to the specified message.
|
| onMessage | | public void onMessage(Message message)(Code) | | Invoked by JMS.
|
| onNewMessage | | protected void onNewMessage(Message msg)(Code) | | |
| send | | public String send(Message msg)(Code) | | Sends a message and returns immediately.
|
| setNewMessageHandler | | public void setNewMessageHandler(MessageHandler newMessageHandler)(Code) | | Sets
MessageHandler that handles uncorrelated messages
received by this endpoint.
Parameters:
newMessageHandler - if null, uncorrelated messages are discarded. |
| start | | protected void start()(Code) | | |
| stop | | protected void stop()(Code) | | |
| waitForMultipleReplies | | public ReplyIterator<Message> waitForMultipleReplies(Message outgoing, Date expirationDate)(Code) | | |
| waitForReply | | public Message waitForReply(Message msg)(Code) | | |
| waitForReply | | public Message waitForReply(Message msg, Date timeout)(Code) | | |
|
|