org.apache.geronimo.security.network.protocol
Class SubjectCarryingChannel

java.lang.Object
  org.activeio.FilterAsyncChannel
      org.apache.geronimo.security.network.protocol.SubjectCarryingChannel

All Implemented Interfaces:

org.activeio.AsyncChannel, org.activeio.AsyncChannelListener, org.activeio.Channel, org.activeio.Disposable, org.activeio.InputAsyncChannel, org.activeio.OutputChannel, org.activeio.Service

public class SubjectCarryingChannel
extends org.activeio.FilterAsyncChannel

SubjectCarryingChannel is a FilterAsynchChannel that allows you to send the subject associated with the current write operation down to the remote end of the channel.

Nested Class Summary

class

SubjectCarryingChannel.SubjectPacketFilter

Field Summary

Fields inherited from class org.activeio.FilterAsyncChannel

channelListener, next

Fields inherited from interface org.activeio.Service

NO_WAIT_TIMEOUT, WAIT_FOREVER_TIMEOUT

Fields inherited from interface org.activeio.Service

NO_WAIT_TIMEOUT, WAIT_FOREVER_TIMEOUT

Constructor Summary

SubjectCarryingChannel(org.activeio.AsyncChannel next)

SubjectCarryingChannel(org.activeio.AsyncChannel next, boolean enableLocalSubjectPublishing, boolean enableRemoteSubjectConsumption)

Method Summary

Subject	getLocalSubject()
Subject	getRemoteSubject()
void	onPacket(org.activeio.Packet packet)
void	write(org.activeio.Packet packet)

Methods inherited from class org.activeio.FilterAsyncChannel

dispose, flush, getAsyncChannelListener, getNext, narrow, onPacketError, setAsyncChannelListener, start, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SubjectCarryingChannel

public SubjectCarryingChannel(org.activeio.AsyncChannel next)

SubjectCarryingChannel

public SubjectCarryingChannel(org.activeio.AsyncChannel next,
                              boolean enableLocalSubjectPublishing,
                              boolean enableRemoteSubjectConsumption)

Method Detail

write

public void write(org.activeio.Packet packet)
           throws IOException

Specified by:

write in interface org.activeio.OutputChannel

Overrides:

write in class org.activeio.FilterAsyncChannel

Throws:

IOException

onPacket

public void onPacket(org.activeio.Packet packet)

Specified by:

onPacket in interface org.activeio.AsyncChannelListener

Overrides:

onPacket in class org.activeio.FilterAsyncChannel

getLocalSubject

public Subject getLocalSubject()

getRemoteSubject

public Subject getRemoteSubject()