org.apache.servicemix.tck
Class AsyncReceiverPojo

java.lang.Object
  extended by org.apache.servicemix.tck.AsyncReceiverPojo
All Implemented Interfaces:
Runnable, javax.jbi.component.ComponentLifeCycle, Receiver

public class AsyncReceiverPojo
extends Object
implements javax.jbi.component.ComponentLifeCycle, Receiver, Runnable

A simple POJO which just implements the ComponentLifeCycle interface and is not dependent on any ServiceMix code.

Version:
$Revision: 2153 $

Field Summary
static String ENDPOINT
           
static QName SERVICE
           
 
Constructor Summary
AsyncReceiverPojo()
           
 
Method Summary
 javax.jbi.component.ComponentContext getContext()
           
 ObjectName getExtensionMBeanName()
           
 MessageList getMessageList()
          Return access to the list of messages being received
 void init(javax.jbi.component.ComponentContext ctx)
           
 void onMessageExchange(javax.jbi.messaging.MessageExchange exchange)
           
 void run()
           
 void shutDown()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

SERVICE

public static final QName SERVICE

ENDPOINT

public static final String ENDPOINT
See Also:
Constant Field Values
Constructor Detail

AsyncReceiverPojo

public AsyncReceiverPojo()
Method Detail

init

public void init(javax.jbi.component.ComponentContext ctx)
          throws javax.jbi.JBIException
Specified by:
init in interface javax.jbi.component.ComponentLifeCycle
Throws:
javax.jbi.JBIException

shutDown

public void shutDown()
              throws javax.jbi.JBIException
Specified by:
shutDown in interface javax.jbi.component.ComponentLifeCycle
Throws:
javax.jbi.JBIException

start

public void start()
           throws javax.jbi.JBIException
Specified by:
start in interface javax.jbi.component.ComponentLifeCycle
Throws:
javax.jbi.JBIException

stop

public void stop()
          throws javax.jbi.JBIException
Specified by:
stop in interface javax.jbi.component.ComponentLifeCycle
Throws:
javax.jbi.JBIException

getExtensionMBeanName

public ObjectName getExtensionMBeanName()
Specified by:
getExtensionMBeanName in interface javax.jbi.component.ComponentLifeCycle

getMessageList

public MessageList getMessageList()
Description copied from interface: Receiver
Return access to the list of messages being received

Specified by:
getMessageList in interface Receiver

run

public void run()
Specified by:
run in interface Runnable

onMessageExchange

public void onMessageExchange(javax.jbi.messaging.MessageExchange exchange)
                       throws javax.jbi.messaging.MessagingException
Throws:
javax.jbi.messaging.MessagingException

getContext

public javax.jbi.component.ComponentContext getContext()


Copyright © 2005-2010 The Apache Software Foundation. All Rights Reserved.