org.jboss.as.ejb3.remote.protocol.versionone

Class ChannelAssociation

java.lang.Object

org.jboss.as.ejb3.remote.protocol.versionone.ChannelAssociation

public class ChannelAssociation
extends Object

Author:

Jaikiran Pai

Constructor Summary

Constructors

Constructor and Description
ChannelAssociation(org.jboss.remoting3.Channel channel)

Method Summary

Modifier and Type	Method and Description
org.jboss.remoting3.MessageOutputStream	acquireChannelMessageOutputStream() Opens and returns a new MessageOutputStream for the Channel represented by this ChannelAssociation.
org.jboss.remoting3.Channel	getChannel()
void	releaseChannelMessageOutputStream(org.jboss.remoting3.MessageOutputStream messageOutputStream) Releases a previously held permit/lock on a message outputstream of a channel and also closes the messageOutputStream

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelAssociation

public ChannelAssociation(org.jboss.remoting3.Channel channel)

Method Detail

acquireChannelMessageOutputStream

public org.jboss.remoting3.MessageOutputStream acquireChannelMessageOutputStream()
                                                                          throws Exception

Opens and returns a new MessageOutputStream for the Channel represented by this ChannelAssociation. Before opening the message outputstream, this method acquires a permit to make sure only a limited number of simultaneous writes are allowed on the channel. The permit acquistion is a blocking wait.

Returns:

Throws:

Exception

releaseChannelMessageOutputStream

public void releaseChannelMessageOutputStream(org.jboss.remoting3.MessageOutputStream messageOutputStream)
                                       throws IOException

Releases a previously held permit/lock on a message outputstream of a channel and also closes the messageOutputStream

Parameters:

messageOutputStream - The message outputstream

Throws:

IOException

getChannel

public org.jboss.remoting3.Channel getChannel()