| java.lang.Object
 org.apache.wsif.util.jms.WSIFJMSDestination
All known Subclasses: org.apache.wsif.util.jms.JMS2HTTPBridgeDestination,
| WSIFJMSDestination | | public class WSIFJMSDestination (Code) | | A WSIFJMSDestination is a pair of queues, one that read from and
the other that is written to. This class provides various methods
for different flavours of reading and writing messages to those
queues. This class hides the JMS interface.
author:
Mark Whitlock |
| asyncMode | | protected boolean asyncMode(Code) | | |
| connection | | protected QueueConnection connection(Code) | | |
| lastMessage | | protected Message lastMessage(Code) | | |
| readQ | | protected Queue readQ(Code) | | |
| sender | | protected QueueSender sender(Code) | | |
| session | | protected QueueSession session(Code) | | |
| syncTempQueue | | protected Queue syncTempQueue(Code) | | |
| timeout | | protected long timeout(Code) | | |
| writeQ | | protected Queue writeQ(Code) | | |
| WSIFJMSDestination | | public WSIFJMSDestination(WSIFJMSFinder finder, long timeout) throws WSIFException(Code) | | Public constructor.
Parameters:
finder - used to find JMS objects.
Parameters:
timeout - is the maximum time to wait on a synchronous receive |
| WSIFJMSDestination | | public WSIFJMSDestination(WSIFJMSFinder finder, String altDestName, long timeout) throws WSIFException(Code) | | Public constructor.
Parameters:
finder - used to find JMS objects.
Parameters:
altdestName - is an alterative JMS provider destination name
Parameters:
timeout - is the maximum time to wait on a synchronous receive |
| createMessage | | public static Message createMessage(Session session, int msgType) throws WSIFException(Code) | | |
| getProperties | | public HashMap getProperties() throws WSIFException(Code) | | Gets all the JMS properties from the previous message that was received.
|
| receive | | public String receive() throws WSIFException(Code) | | Blocking receive for the wsif.syncrequest.timeout
the received message |
| receive | | public Message receive(String id) throws WSIFException(Code) | | Blocking receive waits for a message for the wsif.syncrequest.timeout
Parameters:
id - is the correlation id that the received message must have the received message |
| receive | | public Message receive(String id, long timeout) throws WSIFException(Code) | | Blocking receive waits for a message for the specified timeout
Parameters:
id - is the correlation id that the received message must have
Parameters:
timeout - how long in milliseconds to wait the received message |
| receiveString | | public String receiveString(String id, long timeout) throws WSIFException(Code) | | Blocking receive waits for the specified timeout
the received message |
| send | | public String send(String data) throws WSIFException(Code) | | Send a message to the write queue
Parameters:
data - is the message the id of the message that was sent. |
| send | | public String send(String data, String id) throws WSIFException(Code) | | Send a message to the write queue
Parameters:
data - is the message
Parameters:
id - is the correlation id to set on the message the id of the message that was sent. |
| send | | public String send(Serializable data, String id) throws WSIFException(Code) | | Send a message to the write queue
Parameters:
data - is the message
Parameters:
id - is the correlation id to set on the message the id of the message that was sent. |
| send | | public String send(Message msg, String id, boolean setReplyTo) throws WSIFException(Code) | | Sends a message to the write queue.
Parameters:
message -
Parameters:
id - Correlation id
Parameters:
setReplyTo - If true JMSReplyTo is always set. If false JMSReplyTo is only set if the ReplyTo was explicitly set as a property. |
| setAsyncMode | | public void setAsyncMode(boolean b) throws WSIFException(Code) | | Sets if this destination is to be used for asynchronous requests.
If this destination is to be used for asynchronous requests then a
WSIFJMSAsyncListener will be created to listen for the async responses.
Parameters:
b - true if this destination is to be used for asynchronous requests,otherwise false. |
| setLastMessage | | public void setLastMessage(Message msg)(Code) | | The last message is the most recent message that was received by this
WSIFJMSDestination. The getProperty(s) methods return the properties
that are on the lastMessage. The works fine for sync, but for async
user code will have received the message. So the provider must inform
the WSIFJMSDestination about the lastMessage explicitly so it can
inquire correctly about any jms properties on it.
|
| setProperties | | public void setProperties(HashMap propMap)(Code) | | Sets a HashMap of JMS property value pairs. The property values will be only
be used for the next message that is sent, then all the properties will be reset.
|
| setProperty | | public void setProperty(String name, Object value) throws WSIFException(Code) | | Sets a JMS property to a value. This property value will be only be used for
the next message that is sent, then the property will be reset.
|
| setReplyToQueue | | public void setReplyToQueue() throws WSIFException(Code) | | Set the replyTo queue to a temporary queue.
|
| setReplyToQueue | | public void setReplyToQueue(String replyTo) throws WSIFException(Code) | | Set the replyTo queue.
Parameters:
replyTo - queue name. |
|
|