IceStorm

Class _TopicDisp

java.lang.Object

Ice.ObjectImpl

IceStorm._TopicDisp

All Implemented Interfaces:

Ice.Object, _TopicOperations, _TopicOperationsNC, Topic, java.io.Serializable, java.lang.Cloneable

Direct Known Subclasses:

_TopicTie

public abstract class _TopicDisp
extends Ice.ObjectImpl
implements Topic

Publishers publish information on a particular topic. A topic logically represents a type.

See Also:

TopicManager, Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String[]	__ids
static long	serialVersionUID

Fields inherited from interface IceStorm.Topic

ice_staticId

Constructor Summary

Constructors

Constructor and Description
_TopicDisp()

Method Summary

Modifier and Type	Method and Description
static Ice.DispatchStatus	___destroy(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getLinkInfoSeq(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getName(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getNonReplicatedPublisher(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getPublisher(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___getSubscribers(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___link(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___subscribeAndGetPublisher(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___unlink(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
static Ice.DispatchStatus	___unsubscribe(Topic __obj, IceInternal.Incoming __inS, Ice.Current __current)
Ice.DispatchStatus	__dispatch(IceInternal.Incoming in, Ice.Current __current)
protected void	__readImpl(IceInternal.BasicStream __is)
protected void	__writeImpl(IceInternal.BasicStream __os)
void	destroy() Destroy the topic.
LinkInfo[]	getLinkInfoSeq() Retrieve information on the current links.
java.lang.String	getName() Get the name of this topic.
Ice.ObjectPrx	getNonReplicatedPublisher() Get a non-replicated proxy to a publisher object for this topic.
Ice.ObjectPrx	getPublisher() Get a proxy to a publisher object for this topic.
Ice.Identity[]	getSubscribers() Retrieve the list of subscribers for this topic.
protected void	ice_copyStateFrom(Ice.Object __obj)
java.lang.String	ice_id()
java.lang.String	ice_id(Ice.Current __current)
java.lang.String[]	ice_ids()
java.lang.String[]	ice_ids(Ice.Current __current)
boolean	ice_isA(java.lang.String s)
boolean	ice_isA(java.lang.String s, Ice.Current __current)
static java.lang.String	ice_staticId()
void	link(TopicPrx linkTo, int cost) Create a link to the given topic.
Ice.ObjectPrx	subscribeAndGetPublisher(java.util.Map<java.lang.String,java.lang.String> theQoS, Ice.ObjectPrx subscriber) Subscribe with the given qos to this topic.
void	unlink(TopicPrx linkTo) Destroy the link from this topic to the given topic linkTo.
void	unsubscribe(Ice.ObjectPrx subscriber) Unsubscribe the given subscriber.

Methods inherited from class Ice.ObjectImpl

___ice_id, ___ice_ids, ___ice_isA, ___ice_ping, __checkMode, __read, __read, __readImpl, __write, __write, __writeImpl, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Methods inherited from class java.lang.Object

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

Methods inherited from interface Ice.Object

__read, __read, __write, __write, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Methods inherited from interface IceStorm._TopicOperations

destroy, getLinkInfoSeq, getName, getNonReplicatedPublisher, getPublisher, getSubscribers, link, subscribeAndGetPublisher, unlink, unsubscribe

Field Detail

__ids

public static final java.lang.String[] __ids

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

_TopicDisp

public _TopicDisp()

Method Detail

ice_copyStateFrom

protected void ice_copyStateFrom(Ice.Object __obj)
                          throws java.lang.CloneNotSupportedException

Throws:

java.lang.CloneNotSupportedException

ice_isA

public boolean ice_isA(java.lang.String s)

Specified by:

ice_isA in interface Ice.Object

Overrides:

ice_isA in class Ice.ObjectImpl

ice_isA

public boolean ice_isA(java.lang.String s,
                       Ice.Current __current)

Specified by:

ice_isA in interface Ice.Object

Overrides:

ice_isA in class Ice.ObjectImpl

ice_ids

public java.lang.String[] ice_ids()

Specified by:

ice_ids in interface Ice.Object

Overrides:

ice_ids in class Ice.ObjectImpl

ice_ids

public java.lang.String[] ice_ids(Ice.Current __current)

Specified by:

ice_ids in interface Ice.Object

Overrides:

ice_ids in class Ice.ObjectImpl

ice_id

public java.lang.String ice_id()

Specified by:

ice_id in interface Ice.Object

Overrides:

ice_id in class Ice.ObjectImpl

ice_id

public java.lang.String ice_id(Ice.Current __current)

Specified by:

ice_id in interface Ice.Object

Overrides:

ice_id in class Ice.ObjectImpl

ice_staticId

public static java.lang.String ice_staticId()

destroy

public final void destroy()

Destroy the topic.

Specified by:

destroy in interface _TopicOperationsNC

getLinkInfoSeq

public final LinkInfo[] getLinkInfoSeq()

Retrieve information on the current links.

Specified by:

getLinkInfoSeq in interface _TopicOperationsNC

Returns:

A sequence of LinkInfo objects.

getName

public final java.lang.String getName()

Get the name of this topic.

Specified by:

getName in interface _TopicOperationsNC

Returns:

The name of the topic.

See Also:

_TopicManagerOperations.create(java.lang.String, Ice.Current)

getNonReplicatedPublisher

public final Ice.ObjectPrx getNonReplicatedPublisher()

Get a non-replicated proxy to a publisher object for this topic. To publish data to a topic, the publisher calls getPublisher and then casts to the topic type. An unchecked cast must be used on this proxy.

Specified by:

getNonReplicatedPublisher in interface _TopicOperationsNC

Returns:

A proxy to publish data on this topic.

getPublisher

public final Ice.ObjectPrx getPublisher()

Get a proxy to a publisher object for this topic. To publish data to a topic, the publisher calls getPublisher and then casts to the topic type. An unchecked cast must be used on this proxy. If a replicated IceStorm deployment is used this call may return a replicated proxy.

Specified by:

getPublisher in interface _TopicOperationsNC

Returns:

A proxy to publish data on this topic.

getSubscribers

public final Ice.Identity[] getSubscribers()

Retrieve the list of subscribers for this topic.

Specified by:

getSubscribers in interface _TopicOperationsNC

Returns:

The sequence of Ice identities for the subscriber objects.

link

public final void link(TopicPrx linkTo,
                       int cost)
                throws LinkExists

Create a link to the given topic. All events originating on this topic will also be sent to linkTo.

Specified by:

link in interface _TopicOperationsNC

Parameters:

linkTo - The topic to link to.

cost - The cost to the linked topic.

Throws:

LinkExists - Raised if a link to the same topic already exists.

subscribeAndGetPublisher

public final Ice.ObjectPrx subscribeAndGetPublisher(java.util.Map<java.lang.String,java.lang.String> theQoS,
                                                    Ice.ObjectPrx subscriber)
                                             throws AlreadySubscribed,
                                                    BadQoS,
                                                    InvalidSubscriber

Subscribe with the given qos to this topic. A per-subscriber publisher object is returned.

Specified by:

subscribeAndGetPublisher in interface _TopicOperationsNC

Parameters:

theQoS - The quality of service parameters for this subscription.

subscriber - The subscriber's proxy.

Returns:

The per-subscriber publisher object.

Throws:

AlreadySubscribed - Raised if the subscriber object is already subscribed.

InvalidSubscriber - Raised if the subscriber object is null.

BadQoS - Raised if the requested quality of service is unavailable or invalid.

See Also:

unsubscribe(Ice.ObjectPrx)

unlink

public final void unlink(TopicPrx linkTo)
                  throws NoSuchLink

Destroy the link from this topic to the given topic linkTo.

Specified by:

unlink in interface _TopicOperationsNC

Parameters:

linkTo - The topic to destroy the link to.

Throws:

NoSuchLink - Raised if a link to the topic does not exist.

unsubscribe

public final void unsubscribe(Ice.ObjectPrx subscriber)

Unsubscribe the given subscriber.

Specified by:

unsubscribe in interface _TopicOperationsNC

Parameters:

subscriber - The proxy of an existing subscriber.

See Also:

subscribeAndGetPublisher(java.util.Map<java.lang.String, java.lang.String>, Ice.ObjectPrx)

___getName

public static Ice.DispatchStatus ___getName(Topic __obj,
                                            IceInternal.Incoming __inS,
                                            Ice.Current __current)

___getPublisher

public static Ice.DispatchStatus ___getPublisher(Topic __obj,
                                                 IceInternal.Incoming __inS,
                                                 Ice.Current __current)

___getNonReplicatedPublisher

public static Ice.DispatchStatus ___getNonReplicatedPublisher(Topic __obj,
                                                              IceInternal.Incoming __inS,
                                                              Ice.Current __current)

___subscribeAndGetPublisher

public static Ice.DispatchStatus ___subscribeAndGetPublisher(Topic __obj,
                                                             IceInternal.Incoming __inS,
                                                             Ice.Current __current)

___unsubscribe

public static Ice.DispatchStatus ___unsubscribe(Topic __obj,
                                                IceInternal.Incoming __inS,
                                                Ice.Current __current)

___link

public static Ice.DispatchStatus ___link(Topic __obj,
                                         IceInternal.Incoming __inS,
                                         Ice.Current __current)

___unlink

public static Ice.DispatchStatus ___unlink(Topic __obj,
                                           IceInternal.Incoming __inS,
                                           Ice.Current __current)

___getLinkInfoSeq

public static Ice.DispatchStatus ___getLinkInfoSeq(Topic __obj,
                                                   IceInternal.Incoming __inS,
                                                   Ice.Current __current)

___getSubscribers

public static Ice.DispatchStatus ___getSubscribers(Topic __obj,
                                                   IceInternal.Incoming __inS,
                                                   Ice.Current __current)

___destroy

public static Ice.DispatchStatus ___destroy(Topic __obj,
                                            IceInternal.Incoming __inS,
                                            Ice.Current __current)

__dispatch

public Ice.DispatchStatus __dispatch(IceInternal.Incoming in,
                                     Ice.Current __current)

Specified by:

__dispatch in interface Ice.Object

Overrides:

__dispatch in class Ice.ObjectImpl

__writeImpl

protected void __writeImpl(IceInternal.BasicStream __os)

Overrides:

__writeImpl in class Ice.ObjectImpl

__readImpl

protected void __readImpl(IceInternal.BasicStream __is)

Overrides:

__readImpl in class Ice.ObjectImpl