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

java.lang.Object
  extended byorg.activeio.FilterAsyncChannel
      extended byorg.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.

Version:
$Rev: 355877 $ $Date: 2005-12-11 03:48:27 +0100 (Sun, 11 Dec 2005) $

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
 
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
Throws:
IOException

onPacket

public void onPacket(org.activeio.Packet packet)

getLocalSubject

public Subject getLocalSubject()

getRemoteSubject

public Subject getRemoteSubject()


Copyright © 2003-2007 Apache Software Foundation. All Rights Reserved.