## org.red5.server.messaging
Class InMemoryPullPullPipe

    java.lang.Object
      org.red5.server.messaging.AbstractPipe
          org.red5.server.messaging.InMemoryPullPullPipe

All Implemented Interfaces:
  IMessageInput, IMessageOutput, IPipe

    public class InMemoryPullPullPipe

extends AbstractPipe

A simple in-memory version of pull-pull pipe. It is triggered by an active consumer that pulls messages through it from a pullable provider.

Author:
  The Red5 Project (red5@osflash.org), Steven Gong (steven.gong@gmail.com)

Field Summary

Fields inherited from class org.red5.server.messaging.AbstractPipe
`consumers, listeners, providers`

Constructor Summary
`InMemoryPullPullPipe()`

Method Summary
`IMessage` `pullMessage()` Pull message from this input endpoint.
`IMessage` `pullMessage(long wait)` Pull message from this input endpoint.
`void` `pushMessage(IMessage message)` Push a message to this output endpoint.
`boolean` `subscribe(IConsumer consumer, Map<String,Object> paramMap)` Connect consumer to this pipe.
`boolean` `subscribe(IProvider provider, Map<String,Object> paramMap)` Connect provider to this pipe.

Methods inherited from class org.red5.server.messaging.AbstractPipe
`addPipeConnectionListener, close, fireConsumerConnectionEvent, firePipeConnectionEvent, fireProviderConnectionEvent, getConsumers, getListeners, getProviders, removePipeConnectionListener, sendOOBControlMessage, sendOOBControlMessage, setListeners, unsubscribe, unsubscribe`

Methods inherited from class java.lang.Object
`clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

Constructor Detail

### InMemoryPullPullPipe

    public InMemoryPullPullPipe()

Method Detail

### subscribe

    public boolean subscribe(IConsumer consumer,
                             Map<String,Object> paramMap)

  Connect consumer to this pipe. Doesn't allow to connect one consumer twice. Does register event listeners if instance of IPipeConnectionListener is given.

  Specified by:
    `subscribe` in interface `IMessageInput`
  Overrides:
    `subscribe` in class `AbstractPipe`
  Parameters:
    `consumer` - Consumer
    `paramMap` - Parameters passed with connection, used in concrete pipe implementations
  Returns:
    `true` if consumer was added, `false` otherwise

### subscribe

    public boolean subscribe(IProvider provider,
                             Map<String,Object> paramMap)

  Connect provider to this pipe. Doesn't allow to connect one provider twice. Does register event listeners if instance of IPipeConnectionListener is given.

  Specified by:
    `subscribe` in interface `IMessageOutput`
  Overrides:
    `subscribe` in class `AbstractPipe`
  Parameters:
    `provider` - Provider
    `paramMap` - Parameters passed with connection, used in concrete pipe implementations
  Returns:
    `true` if provider was added, `false` otherwise

### pullMessage

    public IMessage pullMessage()
                         throws IOException

  Pull message from this input endpoint. Return w/o waiting.

  Returns:
    The pulled message or `null` if message is not available.
  Throws:
    `IOException` - on error

### pullMessage

    public IMessage pullMessage(long wait)

  Pull message from this input endpoint. Wait `wait` milliseconds if message is not available.

  Parameters:
    `wait` - milliseconds to wait when message is not available.
  Returns:
    The pulled message or `null` if message is not available.

### pushMessage

    public void pushMessage(IMessage message)

  Push a message to this output endpoint. May block the pusher when output can't handle the message at the time.

  Parameters:
    `message` - Message to be pushed.

Copyright © 2006-2010 The Red5 Project