Package org.objectweb.joram.client.jms.connection

Class MultiThreadSyncChannel

java.lang.Object

org.objectweb.joram.client.jms.connection.MultiThreadSyncChannel

All Implemented Interfaces:

RequestChannel

public class MultiThreadSyncChannel
extends Object
implements RequestChannel

Class wrapping the RequestChannel in order to group the requests. It allows best performances with multiples senders.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	MultiThreadSyncChannel.SyncRound

Field Summary

Fields

Modifier and Type	Field	Description
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 Vector	syncRequests	Synchronized requests.

Constructor Summary

Constructors

Constructor	Description
MultiThreadSyncChannel(RequestChannel rc, int delay, int threshold)

Method Summary

Modifier and Type	Method	Description
void	close()
void	closing()
void	connect()
Identity	getIdentity()
AbstractJmsReply	receive()
void	send(AbstractJmsRequest request)
void	setTimer(Timer timer)

Methods inherited from class java.lang.Object

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

Field Detail

currentRound

private MultiThreadSyncChannel.SyncRound currentRound

Synchronization round.

syncRequests

private Vector syncRequests

Synchronized requests.

multiThreadSyncDelay

private int multiThreadSyncDelay

The maximum time the threads hang if 'multiThreadSync' is true. Either they wake up (wait time out) or they are notified (by the first woken up thread).

multiThreadSyncThreshold

private int multiThreadSyncThreshold

The maximum numbers of threads that hang if 'multiThreadSync' is true.

channel

private RequestChannel channel

The related RequestChannel.

Constructor Detail

MultiThreadSyncChannel

MultiThreadSyncChannel(RequestChannel rc,
                       int delay,
                       int threshold)

Method Detail

send

public void send(AbstractJmsRequest request)
          throws Exception

Specified by:

send in interface RequestChannel

Throws:

Exception

setTimer

public void setTimer(Timer timer)

Specified by:

setTimer in interface RequestChannel

connect

public void connect()
             throws Exception

Specified by:

connect in interface RequestChannel

Throws:

Exception

receive

public AbstractJmsReply receive()
                         throws Exception

Specified by:

receive in interface RequestChannel

Throws:

Exception

close

public void close()

Specified by:

close in interface RequestChannel

closing

public void closing()

Specified by:

closing in interface RequestChannel

getIdentity

public Identity getIdentity()

Specified by:

getIdentity in interface RequestChannel