---
name: "CosNotifyChannelAdmin_SequenceProxyPullSupplier"
section: "3erl"
platform: "linux"
package: "erlang-manpages"
version: "1:19.2.1+dfsg-2+deb9u3"
release: "Debian 9 (Stretch)"
platforms: ["linux"]
url: "https://new.carta.tech/CosNotifyChannelAdmin_SequenceProxyPullSupplier"
---

# CosNotifyChannelAdmin\_SequenceProxyPullSupplier(3erl)

This module implements the OMG CosNotifyChannelAdmin::SequenceProxyPullSupplier interface.

## NAME

CosNotifyChannelAdmin\_SequenceProxyPullSupplier - This module implements the OMG  CosNotifyChannelAdmin::SequenceProxyPullSupplier interface.

## DESCRIPTION

To get access to the record definitions for the structures use: \
 *-include\_lib("cosNotification/include/\*.hrl").*

This module also exports the functions described in:

- \*

  **CosNotifyComm\_NotifySubscribe**

- \*

  **CosNotification\_QoSAdmin**

- \*

  **CosNotifyFilter\_FilterAdmin**

- \*

  **CosNotifyChannelAdmin\_ProxySupplier**

## EXPORTS

**connect\_sequence\_pull\_consumer(SequenceProxyPullSupplier, PullConsumer) -\> Reply**\

Types:

SequenceProxyPullSupplier = #objref\
 PullConsumer = #objref\
 Reply = ok \| {'EXCEPTION', #'CosEventChannelAdmin\_AlreadyConnected'{}}\

This operation connects a *PullConsumer* to the target object. If a connection already exists an exception is raised.

**pull\_structured\_events(SequenceProxyPullSupplier, MaxEvents) -\> Reply**\

Types:

SequenceProxyPullSupplier = #objref\
 MaxEvents = long()\
 Reply = EventBatch \| {'EXCEPTION', #'CosEventChannelAdmin\_Disconnected'{}}\
 EventBatch = \[StructuredEvent\]\
 StructuredEvent = #'CosNotification\_StructuredEvent'{header, filterable\_data, remainder\_of\_body}\
 header = EventHeader\
 filterable\_data = \[#'CosNotification\_Property'{name, value}\]\
 name = string()\
 value = #any\
 remainder\_of\_body = #any\
 EventHeader = #'CosNotification\_EventHeader'{fixed\_header, variable\_header}\
 fixed\_header = FixedEventHeader\
 variable\_header = OptionalHeaderFields\
 FixedEventHeader = #'CosNotification\_FixedEventHeader'{event\_type, event\_name}\
 event\_type = EventType\
 event\_name = string()\
 EventType = #'CosNotification\_EventType'{domain\_name, type\_name}\
 domain\_name = type\_name = string()\
 OptionalHeaderFields = \[#'CosNotification\_Property'{name, value}\]\

A client use this operation to pull next event sequence of maximum length *MaxEvents*. This operation is blocking and will not reply until the requested amount of events can be delivered or the QoS property *PacingInterval* is reached. For more information see the *User's Guide*.

**try\_pull\_structured\_events(SequenceProxyPullSupplier, MaxEvents) -\> Reply**\

Types:

SequenceProxyPullSupplier = #objref\
 MaxEvents = long()\
 Reply = {EventBatch, HasEvent} \| {'EXCEPTION', #'CosEventChannelAdmin\_Disconnected'{}}\
 HasEvent = boolean()\
 EventBatch = \[StructuredEvent\]\
 StructuredEvent = #'CosNotification\_StructuredEvent'{header, filterable\_data, remainder\_of\_body}\
 header = EventHeader\
 filterable\_data = \[#'CosNotification\_Property'{name, value}\]\
 name = string()\
 value = #any\
 remainder\_of\_body = #any\
 EventHeader = #'CosNotification\_EventHeader'{fixed\_header, variable\_header}\
 fixed\_header = FixedEventHeader\
 variable\_header = OptionalHeaderFields\
 FixedEventHeader = #'CosNotification\_FixedEventHeader'{event\_type, event\_name}\
 event\_type = EventType\
 event\_name = string()\
 EventType = #'CosNotification\_EventType'{domain\_name, type\_name}\
 domain\_name = type\_name = string()\
 OptionalHeaderFields = \[#'CosNotification\_Property'{name, value}\]\

This operation pulls an event sequence of the maximum length *MaxEvents*, but do not block if the target object have no events to forward. The outparameter, *HasEvent* is true if the sequence contain any events.

**disconnect\_sequence\_pull\_supplier(SequenceProxyPullSupplier) -\> ok**\

Types:

SequenceProxyPullSupplier = #objref\

This operation cause the target object to close the connection and terminate.