public abstract class ClientNotifForwarder extends Object
| Constructor and Description |
|---|
ClientNotifForwarder(ClassLoader defaultClassLoader,
Map env) |
ClientNotifForwarder(Map env) |
| Modifier and Type | Method and Description |
|---|---|
protected abstract Integer |
addListenerForMBeanRemovedNotif() |
void |
addNotificationListener(Integer listenerID,
ObjectName name,
NotificationListener listener,
NotificationFilter filter,
Object handback,
Subject delegationSubject) |
protected abstract NotificationResult |
fetchNotifs(long clientSequenceNumber,
int maxNotifications,
long timeout)
Called to to fetch notifications from a server.
|
ListenerInfo[] |
getListenerInfo() |
protected abstract void |
lostNotifs(String message,
long number)
Used to send out a notification about lost notifs
|
void |
postReconnection(ClientListenerInfo[] listenerInfos)
Called after reconnection is finished.
|
ClientListenerInfo[] |
preReconnection() |
protected abstract void |
removeListenerForMBeanRemovedNotif(Integer id) |
Integer[] |
removeNotificationListener(ObjectName name) |
Integer[] |
removeNotificationListener(ObjectName name,
NotificationListener listener) |
Integer |
removeNotificationListener(ObjectName name,
NotificationListener listener,
NotificationFilter filter,
Object handback) |
void |
terminate() |
public ClientNotifForwarder(Map env)
public ClientNotifForwarder(ClassLoader defaultClassLoader, Map env)
protected abstract NotificationResult fetchNotifs(long clientSequenceNumber, int maxNotifications, long timeout) throws IOException, ClassNotFoundException
IOExceptionClassNotFoundExceptionprotected abstract Integer addListenerForMBeanRemovedNotif() throws IOException, InstanceNotFoundException
IOExceptionInstanceNotFoundExceptionprotected abstract void removeListenerForMBeanRemovedNotif(Integer id) throws IOException, InstanceNotFoundException, ListenerNotFoundException
protected abstract void lostNotifs(String message, long number)
public void addNotificationListener(Integer listenerID, ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback, Subject delegationSubject) throws IOException, InstanceNotFoundException
IOExceptionInstanceNotFoundExceptionpublic Integer[] removeNotificationListener(ObjectName name, NotificationListener listener) throws ListenerNotFoundException, IOException
ListenerNotFoundExceptionIOExceptionpublic Integer removeNotificationListener(ObjectName name, NotificationListener listener, NotificationFilter filter, Object handback) throws ListenerNotFoundException, IOException
ListenerNotFoundExceptionIOExceptionpublic Integer[] removeNotificationListener(ObjectName name)
public ListenerInfo[] getListenerInfo()
public ClientListenerInfo[] preReconnection() throws IOException
IOExceptionpublic void postReconnection(ClientListenerInfo[] listenerInfos) throws IOException
RMIConnector and ClientIntermediary.IOExceptionpublic void terminate()
Copyright © 2019 Terracotta, Inc.. All rights reserved.