JMSSenderpublic class JMSSender extends org.apache.axis.handlers.BasicHandler | This is meant to be used on a SOAP Client to call a SOAP server. |
| Constructors Summary |
|---|
public JMSSender()
|
| Methods Summary |
|---|
| protected java.util.HashMap | createApplicationProperties(org.apache.axis.MessageContext context)Return a map of properties that makeup the application-specific
for the JMS Messages.
HashMap props = null;
if (context.containsProperty(
JMSConstants.JMS_APPLICATION_MSG_PROPS)) {
props = new HashMap();
props.putAll((Map)context.getProperty(
JMSConstants.JMS_APPLICATION_MSG_PROPS));
}
return props;
| | private java.util.HashMap | createSendProperties(org.apache.axis.MessageContext context)
//I'm not sure why this helper method is private, but
//we need to delegate to factory method that can build the
//application-specific map of properties so make a change to
//delegate here.
HashMap props = createApplicationProperties(context);
if(context.containsProperty(JMSConstants.PRIORITY))
props.put(JMSConstants.PRIORITY,
context.getProperty(JMSConstants.PRIORITY));
if(context.containsProperty(JMSConstants.DELIVERY_MODE))
props.put(JMSConstants.DELIVERY_MODE,
context.getProperty(JMSConstants.DELIVERY_MODE));
if(context.containsProperty(JMSConstants.TIME_TO_LIVE))
props.put(JMSConstants.TIME_TO_LIVE,
context.getProperty(JMSConstants.TIME_TO_LIVE));
if(context.containsProperty(JMSConstants.JMS_CORRELATION_ID))
props.put(JMSConstants.JMS_CORRELATION_ID,
context.getProperty(JMSConstants.JMS_CORRELATION_ID));
return props;
| | public void | invoke(org.apache.axis.MessageContext msgContext)invoke() creates an endpoint, sends the request SOAP message, and then
either reads the response SOAP message or simply returns.
JMSConnector connector = null;
try
{
Object destination = msgContext.getProperty(JMSConstants.DESTINATION);
if(destination == null)
throw new AxisFault("noDestination");
connector = (JMSConnector)msgContext.getProperty(JMSConstants.CONNECTOR);
JMSEndpoint endpoint = null;
if(destination instanceof String)
endpoint = connector.createEndpoint((String)destination);
else
endpoint = connector.createEndpoint((Destination)destination);
ByteArrayOutputStream out = new ByteArrayOutputStream();
msgContext.getRequestMessage().writeTo(out);
HashMap props = createSendProperties(msgContext);
// If the request message contains attachments, set
// a contentType property to go in the outgoing message header
String ret = null;
Message message = msgContext.getRequestMessage();
Attachments mAttachments = message.getAttachmentsImpl();
if (mAttachments != null && 0 != mAttachments.getAttachmentCount())
{
String contentType = mAttachments.getContentType();
if(contentType != null && !contentType.trim().equals(""))
{
props.put("contentType", contentType);
}
}
boolean waitForResponse = true;
if(msgContext.containsProperty(JMSConstants.WAIT_FOR_RESPONSE))
waitForResponse =
((Boolean)msgContext.getProperty(
JMSConstants.WAIT_FOR_RESPONSE)).booleanValue();
if(waitForResponse)
{
long timeout = (long) msgContext.getTimeout();
byte[] response = endpoint.call(out.toByteArray(), timeout, props);
Message msg = new Message(response);
msgContext.setResponseMessage(msg);
}
else
{
endpoint.send(out.toByteArray(), props);
}
}
catch(Exception e)
{
throw new AxisFault("failedSend", e);
}
finally
{
if (connector != null)
JMSConnectorManager.getInstance().release(connector);
}
|
|
