|
Apache CXF API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.cxf.transport.AbstractObservable org.apache.cxf.transport.AbstractConduit org.apache.cxf.transport.jms.JMSConduit
public class JMSConduit
JMSConduit is instantiated by the JMSTransportFactory which is selected by a client if the transport protocol starts with "jms:". JMSConduit converts CXF Messages to JMS Messages and sends the request over a queue or a topic. If the Exchange is not one way it then receives the response and converts it to a CXF Message. This is then provided in the Exchange and also sent to the IncomingObserver.
Field Summary |
---|
Fields inherited from class org.apache.cxf.transport.AbstractConduit |
---|
target |
Fields inherited from class org.apache.cxf.transport.AbstractObservable |
---|
incomingObserver |
Constructor Summary | |
---|---|
JMSConduit(EndpointReferenceType target,
JMSConfiguration jmsConfig,
Bus b)
|
Method Summary | |
---|---|
void |
close()
Close the conduit. |
void |
close(Message msg)
Close the connections associated with the message |
protected void |
finalize()
|
JMSConfiguration |
getJmsConfig()
|
protected Logger |
getLogger()
|
protected static boolean |
isSetReplyTo(Message message)
|
void |
onMessage(javax.jms.Message jmsMessage)
When a message is received on the reply destination the correlation map is searched for the correlationId. |
void |
prepare(Message message)
Prepare the message to be sent. |
protected void |
processReplyMessage(Exchange exchange,
javax.jms.Message jmsMessage)
Process the reply message |
void |
sendExchange(Exchange exchange,
Object request)
Send the JMS message and if the MEP is not oneway receive the response. |
void |
setJmsConfig(JMSConfiguration jmsConfig)
|
Methods inherited from class org.apache.cxf.transport.AbstractConduit |
---|
getTarget, toString |
Methods inherited from class org.apache.cxf.transport.AbstractObservable |
---|
activate, deactivate, getMessageObserver, getTargetReference, getTargetReference, setMessageObserver |
Methods inherited from class java.lang.Object |
---|
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.apache.cxf.transport.Observable |
---|
getMessageObserver, setMessageObserver |
Constructor Detail |
---|
public JMSConduit(EndpointReferenceType target, JMSConfiguration jmsConfig, Bus b)
Method Detail |
---|
public void prepare(Message message) throws IOException
prepare
in interface Conduit
message
- the message to be sent.
IOException
public void close(Message msg) throws IOException
Conduit
close
in interface Conduit
close
in class AbstractConduit
msg
- for which content should be closed.
IOException
public void sendExchange(Exchange exchange, Object request)
exchange
- the Exchange containing the outgoing messagerequest
- the payload of the outgoing JMS messagepublic void onMessage(javax.jms.Message jmsMessage)
onMessage
in interface javax.jms.MessageListener
protected void processReplyMessage(Exchange exchange, javax.jms.Message jmsMessage) throws javax.jms.JMSException
javax.jms.JMSException
public void close()
AbstractConduit
close
in interface Conduit
close
in class AbstractConduit
protected Logger getLogger()
getLogger
in class AbstractObservable
public JMSConfiguration getJmsConfig()
public void setJmsConfig(JMSConfiguration jmsConfig)
protected static boolean isSetReplyTo(Message message)
protected void finalize() throws Throwable
finalize
in class Object
Throwable
|
Apache CXF API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |