com.ebmwebsourcing.jbi.adaptor.impl.mock
Class MockDeliveryChannel

java.lang.Object
  com.ebmwebsourcing.jbi.adaptor.impl.mock.MockDeliveryChannel

All Implemented Interfaces:

javax.jbi.messaging.DeliveryChannel

public class MockDeliveryChannel
extends java.lang.Object
implements javax.jbi.messaging.DeliveryChannel

Constructor Summary

MockDeliveryChannel(java.util.logging.Logger logger)

Method Summary

javax.jbi.messaging.MessageExchange	accept()
javax.jbi.messaging.MessageExchange	accept(long timeoutMS)
void	close()
javax.jbi.messaging.MessageExchangeFactory	createExchangeFactory()
javax.jbi.messaging.MessageExchangeFactory	createExchangeFactory(javax.xml.namespace.QName interfaceName)
javax.jbi.messaging.MessageExchangeFactory	createExchangeFactory(javax.jbi.servicedesc.ServiceEndpoint endpoint)
javax.jbi.messaging.MessageExchangeFactory	createExchangeFactoryForService(javax.xml.namespace.QName serviceName)
javax.jbi.messaging.MessageExchange	dequeueMsgExchangeFromCompToKernel()
void	enqueueMsgExchangeFromKernelToComp(javax.jbi.messaging.MessageExchange msgExchange)
void	send(javax.jbi.messaging.MessageExchange msgExchange)
boolean	sendSync(javax.jbi.messaging.MessageExchange msgExchange)
boolean	sendSync(javax.jbi.messaging.MessageExchange msgExchange, long timeoutMS)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MockDeliveryChannel

public MockDeliveryChannel(java.util.logging.Logger logger)

Method Detail

enqueueMsgExchangeFromKernelToComp

public void enqueueMsgExchangeFromKernelToComp(javax.jbi.messaging.MessageExchange msgExchange)

dequeueMsgExchangeFromCompToKernel

public javax.jbi.messaging.MessageExchange dequeueMsgExchangeFromCompToKernel()

accept

public javax.jbi.messaging.MessageExchange accept()
                                           throws javax.jbi.messaging.MessagingException

Specified by:

accept in interface javax.jbi.messaging.DeliveryChannel

Throws:

javax.jbi.messaging.MessagingException

accept

public javax.jbi.messaging.MessageExchange accept(long timeoutMS)
                                           throws javax.jbi.messaging.MessagingException,
                                                  java.lang.IllegalArgumentException

Specified by:

accept in interface javax.jbi.messaging.DeliveryChannel

Throws:

javax.jbi.messaging.MessagingException

java.lang.IllegalArgumentException

close

public void close()
           throws javax.jbi.messaging.MessagingException

Specified by:

close in interface javax.jbi.messaging.DeliveryChannel

Throws:

javax.jbi.messaging.MessagingException

createExchangeFactory

public javax.jbi.messaging.MessageExchangeFactory createExchangeFactory()

Specified by:

createExchangeFactory in interface javax.jbi.messaging.DeliveryChannel

createExchangeFactory

public javax.jbi.messaging.MessageExchangeFactory createExchangeFactory(javax.xml.namespace.QName interfaceName)

Specified by:

createExchangeFactory in interface javax.jbi.messaging.DeliveryChannel

createExchangeFactory

public javax.jbi.messaging.MessageExchangeFactory createExchangeFactory(javax.jbi.servicedesc.ServiceEndpoint endpoint)

Specified by:

createExchangeFactory in interface javax.jbi.messaging.DeliveryChannel

createExchangeFactoryForService

public javax.jbi.messaging.MessageExchangeFactory createExchangeFactoryForService(javax.xml.namespace.QName serviceName)

Specified by:

createExchangeFactoryForService in interface javax.jbi.messaging.DeliveryChannel

send

public void send(javax.jbi.messaging.MessageExchange msgExchange)
          throws javax.jbi.messaging.MessagingException

Specified by:

send in interface javax.jbi.messaging.DeliveryChannel

Throws:

javax.jbi.messaging.MessagingException

sendSync

public boolean sendSync(javax.jbi.messaging.MessageExchange msgExchange)
                 throws javax.jbi.messaging.MessagingException

Specified by:

sendSync in interface javax.jbi.messaging.DeliveryChannel

Throws:

javax.jbi.messaging.MessagingException

sendSync

public boolean sendSync(javax.jbi.messaging.MessageExchange msgExchange,
                        long timeoutMS)
                 throws javax.jbi.messaging.MessagingException

Specified by:

sendSync in interface javax.jbi.messaging.DeliveryChannel

Throws:

javax.jbi.messaging.MessagingException