Java Doc for ECProxyPushConsumerImpl.java in » Collaboration » JacORB » org » jacorb » notification » servant » Java Source Code / Java DocumentationJava Source Code and Java Documentation
Java Source Code / Java Documentation
1.
6.0 JDK Core
2.
6.0 JDK Modules
3.
6.0 JDK Modules com.sun
4.
6.0 JDK Modules com.sun.java
5.
6.0 JDK Modules sun
6.
6.0 JDK Platform
7.
Ajax
8.
Apache Harmony Java SE
9.
Aspect oriented
10.
Authentication Authorization
11.
Blogger System
12.
Build
13.
Byte Code
14.
Cache
15.
Chart
16.
Chat
17.
Code Analyzer
18.
Collaboration
19.
Content Management System
20.
Database Client
21.
Database DBMS
22.
Database JDBC Connection Pool
23.
Database ORM
24.
Development
25.
EJB Server geronimo
26.
EJB Server GlassFish
27.
EJB Server JBoss 4.2.1
28.
EJB Server resin 3.1.5
29.
ERP CRM Financial
30.
ESB
31.
Forum
32.
GIS
33.
Graphic Library
34.
Groupware
35.
HTML Parser
36.
IDE
37.
IDE Eclipse
38.
IDE Netbeans
39.
Installer
40.
Internationalization Localization
41.
Inversion of Control
42.
Issue Tracking
43.
J2EE
44.
JBoss
45.
JMS
46.
JMX
47.
Library
48.
Mail Clients
49.
Net
50.
Parser
51.
PDF
52.
Portal
53.
Profiler
54.
Project Management
55.
Report
56.
RSS RDF
57.
Rule Engine
58.
Science
59.
Scripting
60.
Search Engine
61.
Security
62.
Sevlet Container
63.
Source Control
64.
Swing Library
65.
Template Engine
66.
Test Coverage
67.
Testing
68.
UML
69.
Web Crawler
70.
Web Framework
71.
Web Mail
72.
Web Server
73.
Web Services
74.
Web Services apache cxf 2.0.1
75.
Web Services AXIS2
76.
Wiki Engine
77.
Workflow Engines
78.
XML
79.
XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation
»
Collaboration
»
JacORB
»
org.jacorb.notification.servant
Source Cross Reference
Class Diagram
Java Document (Java Doc)
java.lang
.Object
org.jacorb.notification.servant
.AbstractProxy
org.jacorb.notification.servant
.AbstractProxyConsumer
org.jacorb.notification.servant
.ProxyPushConsumerImpl
org.jacorb.notification.servant
.ECProxyPushConsumerImpl
ECProxyPushConsumerImpl
public
class ECProxyPushConsumerImpl extends
ProxyPushConsumerImpl
implements ProxyPushConsumerOperations,ECProxyPushConsumerImplMBean
(Code)
author:
Alphonse Bendt
version:
$Id: ECProxyPushConsumerImpl.java,v 1.9 2006/01/12 22:34:54 alphonse.bendt Exp $
Constructor Summary
public
ECProxyPushConsumerImpl
(
IAdmin
admin,
ORB
orb,
POA
poa, Configuration conf,
TaskProcessor
taskProcessor,
MessageFactory
mf)
Method Summary
public
void
connect_push_supplier
(org.omg.CosEventComm.PushSupplier pushSupplier)
public
Servant
newServant
()
Constructor Detail
ECProxyPushConsumerImpl
public
ECProxyPushConsumerImpl(
IAdmin
admin,
ORB
orb,
POA
poa, Configuration conf,
TaskProcessor
taskProcessor,
MessageFactory
mf)
(Code)
Method Detail
connect_push_supplier
public
void connect_push_supplier(org.omg.CosEventComm.PushSupplier pushSupplier) throws AlreadyConnected
(Code)
newServant
public
Servant
newServant()
(Code)
Methods inherited from
org.jacorb.notification.servant.ProxyPushConsumerImpl
public
ProxyType MyType()
(Code)
(Java Doc)
public
void connect_any_push_supplier(org.omg.CosEventComm.PushSupplier pushSupplier) throws AlreadyConnected
(Code)
(Java Doc)
protected
void disconnectClient()
(Code)
(Java Doc)
public
void disconnect_push_consumer()
(Code)
(Java Doc)
public
Servant
newServant()
(Code)
(Java Doc)
public
void push(
Any
event) throws Disconnected
(Code)
(Java Doc)
Fields inherited from
org.jacorb.notification.servant.AbstractProxyConsumer
final
protected
SupplierAdmin supplierAdmin_
(Code)
(Java Doc)
Methods inherited from
org.jacorb.notification.servant.AbstractProxyConsumer
final
public
SupplierAdmin MyAdmin()
(Code)
(Java Doc)
protected
void checkMessageProperties(
Message
m)
(Code)
(Java Doc)
final
protected
void clientDisconnected()
(Code)
(Java Doc)
protected
void connectClient(
org.omg.CORBA.Object
client)
(Code)
(Java Doc)
public
FilterStage
getFirstStage()
(Code)
(Java Doc)
final
public
MessageConsumer
getMessageConsumer()
(Code)
(Java Doc)
final
public
int getMessageCount()
(Code)
(Java Doc)
protected
MessageFactory
getMessageFactory()
(Code)
(Java Doc)
public
boolean getStartTimeSupported()
(Code)
(Java Doc)
public
boolean getStopTimeSupported()
(Code)
(Java Doc)
final NotifySubscribeOperations getSubscriptionListener()
(Code)
(Java Doc)
final
public
List
getSubsequentFilterStages()
(Code)
(Java Doc)
final
public
boolean hasMessageConsumer()
(Code)
(Java Doc)
protected
Message
[] newMessages(StructuredEvent[] events)
(Code)
(Java Doc)
final
public
EventType[] obtain_subscription_types(ObtainInfoMode obtainInfoMode)
(Code)
(Java Doc)
public
void offer_change(EventType[] added, EventType[] removed) throws InvalidEventType
(Code)
(Java Doc)
protected
void processMessage(
Message
mesg)
(Code)
(Java Doc)
protected
void removeListener()
(Code)
(Java Doc)
protected
void schedulePullTask(
MessageSupplier
target)
(Code)
(Java Doc)
public
void setSubsequentDestinations(
List
list)
(Code)
(Java Doc)
Fields inherited from
org.jacorb.notification.servant.AbstractProxy
protected
Configuration config_
(Code)
(Java Doc)
final
protected
Set
eventTypes_
(Code)
(Java Doc)
final
protected
Logger logger_
(Code)
(Java Doc)
final
protected
OfferManager
offerManager_
(Code)
(Java Doc)
final
protected
QoSPropertySet
qosSettings_
(Code)
(Java Doc)
final
protected
SubscriptionManager
subscriptionManager_
(Code)
(Java Doc)
Methods inherited from
org.jacorb.notification.servant.AbstractProxy
abstract
public
ProxyType MyType()
(Code)
(Java Doc)
final
public
org.omg.CORBA.Object
activate()
(Code)
(Java Doc)
final
public
int add_filter(Filter filter)
(Code)
(Java Doc)
protected
void checkDestroyStatus() throws
OBJECT_NOT_EXIST
(Code)
(Java Doc)
protected
void checkIsConnected() throws NotConnected
(Code)
(Java Doc)
protected
void checkIsNotConnected() throws AlreadyConnected
(Code)
(Java Doc)
protected
void checkStillConnected() throws Disconnected
(Code)
(Java Doc)
abstract
protected
void clientDisconnected()
(Code)
(Java Doc)
public
void configure(Configuration conf)
(Code)
(Java Doc)
protected
void connectClient(
org.omg.CORBA.Object
client)
(Code)
(Java Doc)
protected
void connectionResumed()
(Code)
(Java Doc)
protected
void connectionSuspended()
(Code)
(Java Doc)
final
public
void deactivate()
(Code)
(Java Doc)
final
public
void destroy()
(Code)
(Java Doc)
abstract
protected
void disconnectClient()
(Code)
(Java Doc)
public
void dispose()
(Code)
(Java Doc)
public
String
getClientIOR()
(Code)
(Java Doc)
final
public
boolean getConnected()
(Code)
(Java Doc)
final
public
int getErrorCounter()
(Code)
(Java Doc)
final
public
List
getFilters()
(Code)
(Java Doc)
final
public
Integer
getID()
(Code)
(Java Doc)
public
String
getInterFilterGroupOperator()
(Code)
(Java Doc)
public
String
[] getJMXNotificationTypes()
(Code)
(Java Doc)
final
public
String
getJMXObjectName()
(Code)
(Java Doc)
final
public
MappingFilter getLifetimeFilter()
(Code)
(Java Doc)
final
public
String
getMBeanName()
(Code)
(Java Doc)
protected
String
getMBeanType()
(Code)
(Java Doc)
protected
ORB
getORB()
(Code)
(Java Doc)
final
public
POA
getPOA()
(Code)
(Java Doc)
final
public
MappingFilter getPriorityFilter()
(Code)
(Java Doc)
public
String
getStatus()
(Code)
(Java Doc)
protected
TaskProcessor
getTaskProcessor()
(Code)
(Java Doc)
final
public
int[] get_all_filters()
(Code)
(Java Doc)
final
public
Filter get_filter(int n) throws FilterNotFound
(Code)
(Java Doc)
final
public
Property[] get_qos()
(Code)
(Java Doc)
protected
void handleDisconnected(Disconnected e)
(Code)
(Java Doc)
final
public
boolean hasInterFilterGroupOperatorOR()
(Code)
(Java Doc)
final
public
boolean hasLifetimeFilter()
(Code)
(Java Doc)
final
public
boolean hasPriorityFilter()
(Code)
(Java Doc)
final
public
int incErrorCounter()
(Code)
(Java Doc)
final
public
boolean isDestroyed()
(Code)
(Java Doc)
public
boolean isIDPublic()
(Code)
(Java Doc)
public
boolean isSuspended()
(Code)
(Java Doc)
final
public
MappingFilter lifetime_filter()
(Code)
(Java Doc)
final
public
void lifetime_filter(MappingFilter filter)
(Code)
(Java Doc)
final
public
void priority_filter(MappingFilter filter)
(Code)
(Java Doc)
final
public
MappingFilter priority_filter()
(Code)
(Java Doc)
public
void registerDisposable(
Disposable
d)
(Code)
(Java Doc)
abstract
protected
void removeListener()
(Code)
(Java Doc)
final
public
void remove_all_filters()
(Code)
(Java Doc)
final
public
void remove_filter(int n) throws FilterNotFound
(Code)
(Java Doc)
public
void resetErrorCounter()
(Code)
(Java Doc)
final
public
void resume_connection() throws NotConnected, ConnectionAlreadyActive
(Code)
(Java Doc)
protected
void sendNotification(
String
type,
String
message)
(Code)
(Java Doc)
protected
void sendNotification(
String
type,
String
message,
Object
payload)
(Code)
(Java Doc)
void setInterFilterGroupOperatorOR(boolean b)
(Code)
(Java Doc)
public
void setJMXCallback(
JMXManageable.JMXCallback
callback)
(Code)
(Java Doc)
final
public
void set_qos(Property[] qosProps) throws UnsupportedQoS
(Code)
(Java Doc)
final
public
void suspend_connection() throws NotConnected, ConnectionAlreadyInactive
(Code)
(Java Doc)
public
void validate_event_qos(Property[] qosProps, NamedPropertyRangeSeqHolder propSeqHolder)
(Code)
(Java Doc)
final
public
void validate_qos(Property[] props, NamedPropertyRangeSeqHolder propertyRange) throws UnsupportedQoS
(Code)
(Java Doc)
Methods inherited from
java.lang.Object
native
protected
Object
clone() throws
CloneNotSupportedException
(Code)
(Java Doc)
public
boolean equals(
Object
obj)
(Code)
(Java Doc)
protected
void finalize() throws
Throwable
(Code)
(Java Doc)
final native
public
Class
> getClass()
(Code)
(Java Doc)
native
public
int hashCode()
(Code)
(Java Doc)
final native
public
void notify()
(Code)
(Java Doc)
final native
public
void notifyAll()
(Code)
(Java Doc)
public
String
toString()
(Code)
(Java Doc)
final native
public
void wait(long timeout) throws
InterruptedException
(Code)
(Java Doc)
final
public
void wait(long timeout, int nanos) throws
InterruptedException
(Code)
(Java Doc)
final
public
void wait() throws
InterruptedException
(Code)
(Java Doc)
www.java2java.com
|
Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.