IceStorm.TopicManagerPrx

class IceStorm.TopicManagerPrx

Bases: ObjectPrx

Represents an object that manages topics.

Notes

The Slice compiler generated this proxy class from Slice interface ::IceStorm::TopicManager.

static checkedCast(proxy: ObjectPrx | None, facet: str | None = None, context: dict[str, str] | None = None) → TopicManagerPrx | None

Creates a new proxy from an existing proxy after confirming the target object’s type via a remote invocation.

Parameters:

  • proxy (ObjectPrx | None) – The source proxy.

  • facet (str, optional) – A facet name.

  • context (dict[str, str], optional) – The request context.

Returns:

A new proxy with the requested type, or None if the source proxy is None or if the target object does not support the requested type.

Return type:

ObjectPrx | None

static checkedCastAsync(proxy: ObjectPrx | None, facet: str | None = None, context: dict[str, str] | None = None) → Awaitable[TopicManagerPrx | None]

Creates a new proxy from an existing proxy after confirming the target object’s type via a remote invocation.

Parameters:

  • proxy (ObjectPrx | None) – The source proxy.

  • facet (str, optional) – A facet name.

  • context (dict[str, str], optional) – The request context.

Returns:

A new proxy with the requested type, or None if the source proxy is None or if the target object does not support the requested type.

Return type:

ObjectPrx | None

create(name: str, context: dict[str, str] | None = None) → TopicPrx | None

Creates a new topic.

Parameters:

  • name (str) – The name of the topic.

  • context (dict[str, str]) – The request context for the invocation.

Returns:

A proxy to the new topic object. The returned proxy is never null.

Return type:

TopicPrx | None

Raises:

TopicExists – Thrown when a topic with the same name already exists.

createAsync(name: str, context: dict[str, str] | None = None) → Awaitable[TopicPrx | None]

Creates a new topic.

Parameters:

  • name (str) – The name of the topic.

  • context (dict[str, str]) – The request context for the invocation.

Returns:

A proxy to the new topic object. The returned proxy is never null.

Return type:

Awaitable[TopicPrx | None]

createOrRetrieve(name: str, context: dict[str, str] | None = None) → TopicPrx | None

Creates a new topic with the given name, or retrieves the existing topic with this name if it already exists.

Parameters:

  • name (str) – The name of the topic.

  • context (dict[str, str]) – The request context for the invocation.

Returns:

A proxy to the topic object. The returned proxy is never null.

Return type:

TopicPrx | None

createOrRetrieveAsync(name: str, context: dict[str, str] | None = None) → Awaitable[TopicPrx | None]

Creates a new topic with the given name, or retrieves the existing topic with this name if it already exists.

Parameters:

  • name (str) – The name of the topic.

  • context (dict[str, str]) – The request context for the invocation.

Returns:

A proxy to the topic object. The returned proxy is never null.

Return type:

Awaitable[TopicPrx | None]

static ice_staticId() → str

Gets the Slice type ID of the interface associated with this proxy.

Returns:

The type ID, “::Ice::Object”.

Return type:

str

retrieve(name: str, context: dict[str, str] | None = None) → TopicPrx | None

Retrieves a topic by name.

Parameters:

  • name (str) – The name of the topic.

  • context (dict[str, str]) – The request context for the invocation.

Returns:

A proxy to the topic object. The returned proxy is never null.

Return type:

TopicPrx | None

Raises:

NoSuchTopic – Thrown when there is no topic named name.

retrieveAll(context: dict[str, str] | None = None) → dict[str, TopicPrx | None]

Retrieves all topics managed by this topic manager.

Parameters:

context (dict[str, str]) – The request context for the invocation.

Returns:

A dictionary of string, topic proxy pairs.

Return type:

dict[str, TopicPrx | None]

retrieveAllAsync(context: dict[str, str] | None = None) → Awaitable[dict[str, TopicPrx | None]]

Retrieves all topics managed by this topic manager.

Parameters:

context (dict[str, str]) – The request context for the invocation.

Returns:

A dictionary of string, topic proxy pairs.

Return type:

Awaitable[dict[str, TopicPrx | None]]

retrieveAsync(name: str, context: dict[str, str] | None = None) → Awaitable[TopicPrx | None]

Retrieves a topic by name.

Parameters:

  • name (str) – The name of the topic.

  • context (dict[str, str]) – The request context for the invocation.

Returns:

A proxy to the topic object. The returned proxy is never null.

Return type:

Awaitable[TopicPrx | None]

static uncheckedCast(proxy: ObjectPrx, facet: str | None = None) → TopicManagerPrx
static uncheckedCast(proxy: None, facet: str | None = None) → None

Creates a new proxy from an existing proxy.

Parameters:

  • proxy (ObjectPrx | None) – The source proxy.

  • facet (str, optional) – A facet name.

Returns:

A new proxy with the requested type, or None if the source proxy is None.

Return type:

ObjectPrx | None