com.atlassian.bamboo.lingo
Class BambooMultiplexingRequestor

java.lang.Object
  extended by org.logicblaze.lingo.jms.impl.OneWayRequestor
      extended by org.logicblaze.lingo.jms.impl.SingleThreadedRequestor
          extended by org.logicblaze.lingo.jms.impl.MultiplexingRequestor
              extended by com.atlassian.bamboo.lingo.BambooMultiplexingRequestor
All Implemented Interfaces:
javax.jms.MessageListener, org.logicblaze.lingo.jms.Requestor, org.springframework.beans.factory.DisposableBean

public class BambooMultiplexingRequestor
extends org.logicblaze.lingo.jms.impl.MultiplexingRequestor

HACK A class extending lingo's MultiplexingRequestor as a workaround for LINGO-34, which is preventing remote agent shutdown.


Constructor Summary
BambooMultiplexingRequestor(javax.jms.Connection connection, javax.jms.Session session, javax.jms.MessageProducer producer, javax.jms.Destination serverDestination, javax.jms.Destination clientDestination, boolean ownsConnection)
           
BambooMultiplexingRequestor(org.logicblaze.lingo.jms.JmsProducerConfig config, javax.jms.Destination serverDestination, javax.jms.Destination clientDestination)
           
 
Method Summary
 void close()
           
static org.logicblaze.lingo.jms.Requestor newInstance(javax.jms.ConnectionFactory connectionFactory, org.logicblaze.lingo.jms.JmsProducerConfig config, javax.jms.Destination destination, javax.jms.Destination responseDestination)
           
 javax.jms.Message request(javax.jms.Destination destination, javax.jms.Message message, long timeout)
           
 void request(javax.jms.Destination destination, javax.jms.Message message, org.logicblaze.lingo.jms.ReplyHandler handler, long timeout)
           
 
Methods inherited from class org.logicblaze.lingo.jms.impl.MultiplexingRequestor
createJMSException, doSend, getRequestMap, newInstance, onMessage, receive, registerHandler, request, setRequestMap
 
Methods inherited from class org.logicblaze.lingo.jms.impl.SingleThreadedRequestor
createTemporaryDestination, getInboundDestination, getReceiver, isDeleteTemporaryDestinationsOnClose, populateHeaders, setDeleteTemporaryDestinationsOnClose
 
Methods inherited from class org.logicblaze.lingo.jms.impl.OneWayRequestor
createCorrelationID, destroy, doSend, getConnection, getDeliveryMode, getMessageProducer, getPriority, getSession, getTimeToLive, newInstance, nextCounter, send, send, send, setDeliveryMode, setPriority, setTimeToLive, validateDestination
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

BambooMultiplexingRequestor

public BambooMultiplexingRequestor(org.logicblaze.lingo.jms.JmsProducerConfig config,
                                   javax.jms.Destination serverDestination,
                                   javax.jms.Destination clientDestination)
                            throws javax.jms.JMSException
Throws:
javax.jms.JMSException

BambooMultiplexingRequestor

public BambooMultiplexingRequestor(javax.jms.Connection connection,
                                   javax.jms.Session session,
                                   javax.jms.MessageProducer producer,
                                   javax.jms.Destination serverDestination,
                                   javax.jms.Destination clientDestination,
                                   boolean ownsConnection)
                            throws javax.jms.JMSException
Throws:
javax.jms.JMSException
Method Detail

newInstance

public static org.logicblaze.lingo.jms.Requestor newInstance(javax.jms.ConnectionFactory connectionFactory,
                                                             org.logicblaze.lingo.jms.JmsProducerConfig config,
                                                             javax.jms.Destination destination,
                                                             javax.jms.Destination responseDestination)
                                                      throws javax.jms.JMSException
Throws:
javax.jms.JMSException

request

public javax.jms.Message request(javax.jms.Destination destination,
                                 javax.jms.Message message,
                                 long timeout)
                          throws javax.jms.JMSException
Specified by:
request in interface org.logicblaze.lingo.jms.Requestor
Overrides:
request in class org.logicblaze.lingo.jms.impl.MultiplexingRequestor
Throws:
javax.jms.JMSException

request

public void request(javax.jms.Destination destination,
                    javax.jms.Message message,
                    org.logicblaze.lingo.jms.ReplyHandler handler,
                    long timeout)
             throws javax.jms.JMSException
Specified by:
request in interface org.logicblaze.lingo.jms.Requestor
Overrides:
request in class org.logicblaze.lingo.jms.impl.MultiplexingRequestor
Throws:
javax.jms.JMSException

close

public void close()
           throws javax.jms.JMSException
Specified by:
close in interface org.logicblaze.lingo.jms.Requestor
Overrides:
close in class org.logicblaze.lingo.jms.impl.SingleThreadedRequestor
Throws:
javax.jms.JMSException


Copyright © 2009 Atlassian Pty Ltd. All Rights Reserved.