com.atlassian.bamboo.lingo
Class BambooMultiplexingRequestor

java.lang.Object
  org.logicblaze.lingo.jms.impl.OneWayRequestor
      org.logicblaze.lingo.jms.impl.SingleThreadedRequestor
          org.logicblaze.lingo.jms.impl.MultiplexingRequestor
              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