Package com.caplin.datasource.notification.impl

Class NotificationProviderInternalImpl

java.lang.Object

com.caplin.datasource.notification.impl.NotificationProviderInternalImpl

All Implemented Interfaces:

com.caplin.container.impl.cache.CacheMissListener, NotificationProviderInternal

@JMXBean
public class NotificationProviderInternalImpl
extends Object
implements NotificationProviderInternal, com.caplin.container.impl.cache.CacheMissListener

Constructor Summary

Constructors

Constructor	Description
NotificationProviderInternalImpl(com.caplin.container.impl.Runtime runtime, NotificationConfiguration configuration, NotificationApplicationListener listener)

Method Summary

Modifier and Type	Method	Description
void	closeChannel(String username)
void	deleteNotification(String username, String notificationId)
Long	getChannelCount()
String	getChannelNamespace()
Date	getInstantiationTime()
String	getItemNamespace()
String	getMonitoringKey()
String	getSourceName()
String	getVersion()
Boolean	isNotificationUsingImageFlag()
void	onCacheMiss(String subject)
void	onContainerDiscard(String subject)
void	onContainerRequest(String subject)
void	onContribReceived(String subject, Map<String,String> fields)
void	onRecordDiscard(String subject)
void	onRecordRequest(String subject)
NotificationChannel	openChannel(String username)
void	publishNotification(String username, Notification notification)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

NotificationProviderInternalImpl

public NotificationProviderInternalImpl(com.caplin.container.impl.Runtime runtime,
 NotificationConfiguration configuration,
 NotificationApplicationListener listener)

Method Details

publishNotification

public void publishNotification(String username,
 Notification notification)

Specified by:

publishNotification in interface NotificationProviderInternal

deleteNotification

public void deleteNotification(String username,
 String notificationId)

Specified by:

deleteNotification in interface NotificationProviderInternal

onContribReceived

public void onContribReceived(String subject,
 Map<String,String> fields)

Specified by:

onContribReceived in interface NotificationProviderInternal

onContainerRequest

public void onContainerRequest(String subject)

Specified by:

onContainerRequest in interface NotificationProviderInternal

onContainerDiscard

public void onContainerDiscard(String subject)

Specified by:

onContainerDiscard in interface NotificationProviderInternal

onRecordRequest

public void onRecordRequest(String subject)

Specified by:

onRecordRequest in interface NotificationProviderInternal

onRecordDiscard

public void onRecordDiscard(String subject)

Specified by:

onRecordDiscard in interface NotificationProviderInternal

openChannel

public NotificationChannel openChannel(String username)

Specified by:

openChannel in interface NotificationProviderInternal

closeChannel

public void closeChannel(String username)

Specified by:

closeChannel in interface NotificationProviderInternal

onCacheMiss

public void onCacheMiss(String subject)

Specified by:

onCacheMiss in interface com.caplin.container.impl.cache.CacheMissListener

getVersion

public String getVersion()

Specified by:

getVersion in interface NotificationProviderInternal

getChannelCount

@JMXBeanAttribute(name="channel-count",
                  description="Total open channels associated with this provider")
public Long getChannelCount()

getChannelNamespace

@JMXBeanAttribute(name="channel-namespace",
                  description="Namespace this channel is registered on")
public String getChannelNamespace()

getItemNamespace

@JMXBeanAttribute(name="item-namespace",
                  description="Namespace items associated with this channel are registered on")
public String getItemNamespace()

getInstantiationTime

@JMXBeanAttribute(name="instantiation-time",
                  description="Time at which this notification provider was instantiated")
public Date getInstantiationTime()

isNotificationUsingImageFlag

@JMXBeanAttribute(name="notification-image-flags",
                  description="Notification image flags are being used when true")
public Boolean isNotificationUsingImageFlag()

getSourceName

@JMXBeanAttribute(name="source-name",
                  description="Source name associated with this provider")
public String getSourceName()

getMonitoringKey

@JMXBeanKey
public String getMonitoringKey()

toString

public String toString()

Overrides:

toString in class Object