org.jbpm.task.service.jms
Class JMSTaskClientConnector

java.lang.Object
  extended by org.jbpm.task.service.jms.JMSTaskClientConnector
All Implemented Interfaces:
TaskClientConnector

public class JMSTaskClientConnector
extends Object
implements TaskClientConnector


Nested Class Summary
protected  class JMSTaskClientConnector.Responder
           
 
Field Summary
protected  javax.jms.QueueConnection connection
           
protected  AtomicInteger counter
           
protected  BaseJMSHandler handler
           
protected  String name
           
protected  javax.jms.Queue queue
           
protected  javax.jms.Queue responseQueue
           
protected  javax.jms.QueueSession session
           
 
Constructor Summary
JMSTaskClientConnector(String name, BaseJMSHandler handler, Properties connectionProperties, Context context)
           
 
Method Summary
 boolean connect()
           
 boolean connect(String address, int port)
           
 void disconnect()
           
 AtomicInteger getCounter()
           
 BaseHandler getHandler()
           
 String getName()
           
 void write(Object object)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

connection

protected javax.jms.QueueConnection connection

session

protected javax.jms.QueueSession session

queue

protected javax.jms.Queue queue

responseQueue

protected javax.jms.Queue responseQueue

handler

protected final BaseJMSHandler handler

name

protected final String name

counter

protected AtomicInteger counter
Constructor Detail

JMSTaskClientConnector

public JMSTaskClientConnector(String name,
                              BaseJMSHandler handler,
                              Properties connectionProperties,
                              Context context)
Method Detail

connect

public boolean connect(String address,
                       int port)
Specified by:
connect in interface TaskClientConnector

connect

public boolean connect()
Specified by:
connect in interface TaskClientConnector

disconnect

public void disconnect()
Specified by:
disconnect in interface TaskClientConnector

write

public void write(Object object)
Specified by:
write in interface TaskClientConnector

getCounter

public AtomicInteger getCounter()
Specified by:
getCounter in interface TaskClientConnector

getHandler

public BaseHandler getHandler()
Specified by:
getHandler in interface TaskClientConnector

getName

public String getName()
Specified by:
getName in interface TaskClientConnector


Copyright © 2001-2011 JBoss by Red Hat. All Rights Reserved.