jBPM distribution 6.0.0.Beta1

org.jbpm.task.service.hornetq
Class HornetQTaskClientConnector

java.lang.Object
  extended by org.jbpm.task.service.hornetq.HornetQTaskClientConnector
All Implemented Interfaces:
TaskClientConnector

public class HornetQTaskClientConnector
extends Object
implements TaskClientConnector


Field Summary
protected  AtomicInteger counter
           
protected  BaseClientHandler handler
           
protected  String name
           
protected  org.hornetq.api.core.client.ClientSession session
           
 
Constructor Summary
HornetQTaskClientConnector(String name, BaseClientHandler handler)
           
 
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

session

protected org.hornetq.api.core.client.ClientSession session

handler

protected final BaseClientHandler handler

name

protected final String name

counter

protected AtomicInteger counter
Constructor Detail

HornetQTaskClientConnector

public HornetQTaskClientConnector(String name,
                                  BaseClientHandler handler)
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()
                throws Exception
Specified by:
disconnect in interface TaskClientConnector
Throws:
Exception

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

jBPM distribution 6.0.0.Beta1

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