|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.client.jms.connection.MultiThreadSyncChannel
public class MultiThreadSyncChannel
Class wrapping the RequestChannel
in order to group the
requests. It allows best performances with multiples senders.
Nested Class Summary | |
---|---|
private static class |
MultiThreadSyncChannel.SyncRound
|
Field Summary | |
---|---|
private RequestChannel |
channel
The related RequestChannel. |
private MultiThreadSyncChannel.SyncRound |
currentRound
Synchronization round. |
private int |
multiThreadSyncDelay
The maximum time the threads hang if 'multiThreadSync' is true. |
private int |
multiThreadSyncThreshold
The maximum numbers of threads that hang if 'multiThreadSync' is true. |
private java.util.Vector |
syncRequests
Synchronized requests. |
Constructor Summary | |
---|---|
MultiThreadSyncChannel(RequestChannel rc,
int delay,
int threshold)
|
Method Summary | |
---|---|
void |
close()
|
void |
closing()
|
void |
connect()
|
AbstractJmsReply |
receive()
|
void |
send(AbstractJmsRequest request)
|
void |
setTimer(java.util.Timer timer)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
private MultiThreadSyncChannel.SyncRound currentRound
private java.util.Vector syncRequests
private int multiThreadSyncDelay
private int multiThreadSyncThreshold
private RequestChannel channel
Constructor Detail |
---|
MultiThreadSyncChannel(RequestChannel rc, int delay, int threshold)
Method Detail |
---|
public void send(AbstractJmsRequest request) throws java.lang.Exception
send
in interface RequestChannel
java.lang.Exception
public void setTimer(java.util.Timer timer)
setTimer
in interface RequestChannel
public void connect() throws java.lang.Exception
connect
in interface RequestChannel
java.lang.Exception
public AbstractJmsReply receive() throws java.lang.Exception
receive
in interface RequestChannel
java.lang.Exception
public void close()
close
in interface RequestChannel
public void closing()
closing
in interface RequestChannel
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |