|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.logicblaze.lingo.jms.marshall.DefaultMarshaller
org.logicblaze.lingo.jms.marshall.XStreamMarshaller
public class XStreamMarshaller
Uses XStream to marshall requests and responses into and out of messages.
Field Summary |
---|
Fields inherited from class org.logicblaze.lingo.jms.marshall.DefaultMarshaller |
---|
headerMarshaller, nativeHeaderMarshaller |
Constructor Summary | |
---|---|
XStreamMarshaller()
|
Method Summary | |
---|---|
javax.jms.Message |
createObjectMessage(javax.jms.Session session,
java.lang.Object value)
Creates a message for a Java Object for when distributing objects in collections |
javax.jms.Message |
createRequestMessage(Requestor requestor,
LingoInvocation invocation)
Creates the request message |
javax.jms.Message |
createResponseMessage(javax.jms.Session session,
org.springframework.remoting.support.RemoteInvocationResult result,
javax.jms.Message requestMessage)
Creates the response message |
protected com.thoughtworks.xstream.XStream |
createXStream()
|
org.springframework.remoting.support.RemoteInvocationResult |
extractInvocationResult(javax.jms.Message message)
Extracts the invocation result from the response message |
protected java.lang.Object |
fromXML(java.lang.String xml)
|
com.thoughtworks.xstream.XStream |
getXStream()
|
java.lang.Object |
readMessage(javax.jms.Message message)
Extracts the body from the given JMS message |
org.springframework.remoting.support.RemoteInvocation |
readRemoteInvocation(javax.jms.Message message)
Read a RemoteInvocation from the given JMS message |
void |
setXStream(com.thoughtworks.xstream.XStream xStream)
|
protected java.lang.String |
toXML(java.lang.Object object)
|
Methods inherited from class org.logicblaze.lingo.jms.marshall.DefaultMarshaller |
---|
addResponseMessageHeaders, appendMessageHeaders, appendMessageHeaders, handleInvocationHeaders, handleInvocationResultHeaders, handleMessageHeaders, isIgnoreInvalidMessages, onInvalidClientMessage, onInvalidMessage, setHeaderMarshaller, setIgnoreInvalidMessages |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public XStreamMarshaller()
Method Detail |
---|
public javax.jms.Message createRequestMessage(Requestor requestor, LingoInvocation invocation) throws javax.jms.JMSException
Marshaller
createRequestMessage
in interface Marshaller
createRequestMessage
in class DefaultMarshaller
invocation
- the remote invocation to send
javax.jms.JMSException
- if the message could not be createdpublic javax.jms.Message createResponseMessage(javax.jms.Session session, org.springframework.remoting.support.RemoteInvocationResult result, javax.jms.Message requestMessage) throws javax.jms.JMSException
Marshaller
createResponseMessage
in interface Marshaller
createResponseMessage
in class DefaultMarshaller
session
- the JMS session to useresult
- the result invocationrequestMessage
- the original request message
javax.jms.JMSException
- if the message could not be createdpublic org.springframework.remoting.support.RemoteInvocationResult extractInvocationResult(javax.jms.Message message) throws javax.jms.JMSException
Marshaller
extractInvocationResult
in interface Marshaller
extractInvocationResult
in class DefaultMarshaller
message
- the response message
javax.jms.JMSException
- is thrown if a JMS exception occurspublic org.springframework.remoting.support.RemoteInvocation readRemoteInvocation(javax.jms.Message message) throws javax.jms.JMSException
Marshaller
readRemoteInvocation
in interface Marshaller
readRemoteInvocation
in class DefaultMarshaller
message
- current JMS message
javax.jms.JMSException
public javax.jms.Message createObjectMessage(javax.jms.Session session, java.lang.Object value) throws javax.jms.JMSException
Marshaller
createObjectMessage
in interface Marshaller
createObjectMessage
in class DefaultMarshaller
javax.jms.JMSException
public java.lang.Object readMessage(javax.jms.Message message) throws javax.jms.JMSException
Marshaller
readMessage
in interface Marshaller
readMessage
in class DefaultMarshaller
javax.jms.JMSException
public com.thoughtworks.xstream.XStream getXStream()
public void setXStream(com.thoughtworks.xstream.XStream xStream)
protected com.thoughtworks.xstream.XStream createXStream()
protected java.lang.Object fromXML(java.lang.String xml)
protected java.lang.String toXML(java.lang.Object object)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |