org.primefaces.push.impl

Class EventBusImpl

java.lang.Object

org.primefaces.push.impl.EventBusImpl

All Implemented Interfaces:

EventBus

public class EventBusImpl
extends Object
implements EventBus

Nested Class Summary

Nested classes/interfaces inherited from interface org.primefaces.push.EventBus

EventBus.Reply

Constructor Summary

Constructors

Constructor and Description
EventBusImpl(org.atmosphere.cpr.MetaBroadcaster metaBroadcaster)

Method Summary

Modifier and Type	Method and Description
EventBus	publish(Object o) Fire an object to all connected RemoteEndpoint
EventBus	publish(String path, Object o) Fire an object to RemoteEndpoint that connected using the path value.
EventBus	publish(String path, Object o, EventBus.Reply r) Fire an object to RemoteEndpoint that connected using the path value.
<T> Future<T>	schedule(String path, T t, int time, TimeUnit unit) Schedule a period push operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

EventBusImpl

public EventBusImpl(org.atmosphere.cpr.MetaBroadcaster metaBroadcaster)

Method Detail

publish

public EventBus publish(Object o)

Description copied from interface: EventBus

Fire an object to all connected RemoteEndpoint

Specified by:

publish in interface EventBus

Parameters:

o - an Object

Returns:

this

publish

public EventBus publish(String path,
                        Object o)

Description copied from interface: EventBus

Fire an object to RemoteEndpoint that connected using the path value.

Specified by:

publish in interface EventBus

Parameters:

path - A String starting with '/'

o - an Object

Returns:

this

publish

public EventBus publish(String path,
                        Object o,
                        EventBus.Reply r)

Description copied from interface: EventBus

Fire an object to RemoteEndpoint that connected using the path value.

Specified by:

publish in interface EventBus

Parameters:

path - A String starting with '/'

o - an Object

r - an EventBus.Reply

Returns:

this

schedule

public <T> Future<T> schedule(String path,
                              T t,
                              int time,
                              TimeUnit unit)

Description copied from interface: EventBus

Schedule a period push operation.

Specified by:

schedule in interface EventBus

Type Parameters:

T - The type of the message

Parameters:

path - a channel of communication.

t - a message

time - the time

unit - the @TimeUnit

Returns:

a Future that can used to cancel the periodic push