org.objectweb.dream.queue.keyed
Class KeyedIncomingHandlerNonBlockingImpl

java.lang.Object
  extended by org.objectweb.dream.AbstractComponent
      extended by org.objectweb.dream.queue.keyed.KeyedIncomingHandlerNonBlockingImpl
All Implemented Interfaces:
ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, KeyedPush, BindingController, LifeCycleController

public class KeyedIncomingHandlerNonBlockingImpl
extends AbstractComponent
implements KeyedPush

A push incoming handler that implements the KeyedPushinterface. It adds pushedmessages into a bufferbound to it. This component uses blocking calls for adding messages into the buffer.


Field Summary
protected static String[] CLIENT_INTERFACE_NAMES
          The names of client interfaces.
protected  KeyedBufferAdd keyedBufferAddItf
          The buffer into which pushed messages are added.
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, fcNeedAsyncStart, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.dream.queue.keyed.KeyedPush
IN_KEYED_PUSH_ITF_NAME, OUT_KEYED_PUSH_ITF_NAME
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
KeyedIncomingHandlerNonBlockingImpl()
           
 
Method Summary
 void bindFc(String clientItfName, Object serverItf)
           
 String[] listFc()
           
 void push(Message message, Object key)
          Gives a message to a component.
 
Methods inherited from class org.objectweb.dream.AbstractComponent
beforeFirstStart, bindFc, getFcNeedAsyncStart, getFcState, initComponent, lookupFc, prepareStopFc, setLogger, startFc, stopFc, unbindFc
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

CLIENT_INTERFACE_NAMES

protected static final String[] CLIENT_INTERFACE_NAMES
The names of client interfaces.


keyedBufferAddItf

protected KeyedBufferAdd keyedBufferAddItf
The buffer into which pushed messages are added.

Constructor Detail

KeyedIncomingHandlerNonBlockingImpl

public KeyedIncomingHandlerNonBlockingImpl()
Method Detail

push

public void push(Message message,
                 Object key)
          throws PushException
Description copied from interface: KeyedPush
Gives a message to a component.

Specified by:
push in interface KeyedPush
Parameters:
message - the message to give to the component.
key - the key that is associated with the pushed message.
Throws:
PushException - if an exception occurs.
See Also:
KeyedPush.push(Message, Object)

listFc

public String[] listFc()
Specified by:
listFc in interface BindingController
See Also:
BindingController.listFc()

bindFc

public void bindFc(String clientItfName,
                   Object serverItf)
            throws NoSuchInterfaceException,
                   IllegalBindingException,
                   IllegalLifeCycleException
Specified by:
bindFc in interface BindingController
Overrides:
bindFc in class AbstractComponent
Throws:
NoSuchInterfaceException
IllegalBindingException
IllegalLifeCycleException
See Also:
BindingController.bindFc(String, Object)


Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.