| java.lang.Object org.objectweb.celtix.bus.transports.jms.JMSTransportBase
All known Subclasses: org.objectweb.celtix.bus.transports.jms.JMSClientTransport, org.objectweb.celtix.bus.transports.jms.JMSServerTransport,
JMSTransportBase | public class JMSTransportBase (Code) | | |
Constructor Summary | |
public | JMSTransportBase(Bus b, EndpointReferenceType epr, boolean isServer) |
jmsAddressPolicy | protected JMSAddressPolicyType jmsAddressPolicy(Code) | | |
queueDestinationStyle | protected boolean queueDestinationStyle(Code) | | |
replyDestination | protected Destination replyDestination(Code) | | |
targetDestination | protected Destination targetDestination(Code) | | |
targetEndpoint | protected EndpointReferenceType targetEndpoint(Code) | | |
JMSTransportBase | public JMSTransportBase(Bus b, EndpointReferenceType epr, boolean isServer) throws WSDLException(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) | | |
getJmsAddressDetails | final public JMSAddressPolicyType getJmsAddressDetails()(Code) | | |
getReplyTotAddrUriFromJMSAddrPolicy | protected String getReplyTotAddrUriFromJMSAddrPolicy()(Code) | | |
getTimeToLive | protected long getTimeToLive(JMSMessageHeadersType headers)(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(Message message, MessageContext context, 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 |
|
|