| java.lang.Object
 org.apache.cxf.transport.jms.JMSTransportBase
| JMSTransportBase | | public class JMSTransportBase (Code) | | |
| endpointInfo | | protected EndpointInfo endpointInfo(Code) | | |
| replyDestination | | protected Destination replyDestination(Code) | | |
| targetDestination | | protected Destination targetDestination(Code) | | |
| JMSTransportBase | | public JMSTransportBase(Bus b, EndpointInfo endpoint, boolean isServer, String suffix, JMSTransport transport)(Code) | | |
| connected | | protected void connected(Destination target, Destination reply, JMSSessionFactory factory)(Code) | | Callback from the JMSProviderHub indicating the ClientTransport has
been sucessfully connected.
Parameters:
targetDestination - the target destination
Parameters:
sessionFactory - used to get access to a pooled JMS resources |
| getAddrUriFromJMSAddrPolicy | | protected String getAddrUriFromJMSAddrPolicy()(Code) | | |
| getCorrelationId | | protected String getCorrelationId(JMSMessageHeadersType headers)(Code) | | |
| getJMSDeliveryMode | | protected int getJMSDeliveryMode(JMSMessageHeadersType headers)(Code) | | |
| getJMSPriority | | protected int getJMSPriority(JMSMessageHeadersType headers)(Code) | | |
| getReplyTotAddrUriFromJMSAddrPolicy | | protected String getReplyTotAddrUriFromJMSAddrPolicy()(Code) | | |
| getTimeToLive | | protected long getTimeToLive(JMSMessageHeadersType headers)(Code) | | |
| isDestinationStyleQueue | | protected boolean isDestinationStyleQueue()(Code) | | |
| marshal | | protected Message marshal(Object payload, Session session, Destination replyTo, String messageType) throws JMSException(Code) | | Create a JMS of the appropriate type populated with the given payload.
Parameters:
payload - the message payload, expected to be either of typeString or byte[] depending on payload type
Parameters:
session - the JMS session
Parameters:
replyTo - the ReplyTo destination if any a JMS of the appropriate type populated with the given payload |
| populateIncomingContext | | protected JMSMessageHeadersType populateIncomingContext(javax.jms.Message message, org.apache.cxf.message.Message inMessage, String headerType) throws JMSException(Code) | | |
| setMessageProperties | | protected void setMessageProperties(JMSMessageHeadersType headers, Message message) throws JMSException(Code) | | |
| unmarshal | | protected Object unmarshal(Message message, String messageType) throws JMSException(Code) | | Unmarshal the payload of an incoming message.
Parameters:
message - the incoming message the unmarshalled message payload, either of type String orbyte[] depending on payload type |
|
|