本文整理汇总了Java中com.google.ipc.invalidation.ticl.Statistics.ListenerEventType类的典型用法代码示例。如果您正苦于以下问题:Java ListenerEventType类的具体用法?Java ListenerEventType怎么用?Java ListenerEventType使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ListenerEventType类属于com.google.ipc.invalidation.ticl.Statistics包,在下文中一共展示了ListenerEventType类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: invalidate
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void invalidate(final InvalidationClient client, final Invalidation invalidation,
final AckHandle ackHandle) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
Preconditions.checkNotNull(ackHandle);
listenerScheduler.schedule(NO_DELAY, new NamedRunnable("CheckingInvalListener.invalidate") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.INVALIDATE);
delegate.invalidate(client, invalidation, ackHandle);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:14,代码来源:CheckingInvalidationListener.java
示例2: invalidateUnknownVersion
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void invalidateUnknownVersion(final InvalidationClient client, final ObjectId objectId,
final AckHandle ackHandle) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
Preconditions.checkNotNull(ackHandle);
listenerScheduler.schedule(NO_DELAY,
new NamedRunnable("CheckingInvalListener.invalidateUnknownVersion") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.INVALIDATE_UNKNOWN);
delegate.invalidateUnknownVersion(client, objectId, ackHandle);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:15,代码来源:CheckingInvalidationListener.java
示例3: invalidateAll
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void invalidateAll(final InvalidationClient client, final AckHandle ackHandle) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
Preconditions.checkNotNull(ackHandle);
listenerScheduler.schedule(NO_DELAY, new NamedRunnable("CheckingInvalListener.invalidateAll") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.INVALIDATE_ALL);
delegate.invalidateAll(client, ackHandle);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:13,代码来源:CheckingInvalidationListener.java
示例4: informRegistrationFailure
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void informRegistrationFailure(final InvalidationClient client, final ObjectId objectId,
final boolean isTransient, final String errorMessage) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
listenerScheduler.schedule(NO_DELAY, new NamedRunnable("CheckingInvalListener.regFailure") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.INFORM_REGISTRATION_FAILURE);
delegate.informRegistrationFailure(client, objectId, isTransient, errorMessage);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:13,代码来源:CheckingInvalidationListener.java
示例5: informRegistrationStatus
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void informRegistrationStatus(final InvalidationClient client, final ObjectId objectId,
final RegistrationState regState) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
listenerScheduler.schedule(NO_DELAY, new NamedRunnable("CheckingInvalListener.regStatus") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.INFORM_REGISTRATION_STATUS);
delegate.informRegistrationStatus(client, objectId, regState);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:13,代码来源:CheckingInvalidationListener.java
示例6: reissueRegistrations
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void reissueRegistrations(final InvalidationClient client, final byte[] prefix,
final int prefixLen) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
listenerScheduler.schedule(NO_DELAY, new NamedRunnable("CheckingInvalListener.reissueRegs") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.REISSUE_REGISTRATIONS);
delegate.reissueRegistrations(client, prefix, prefixLen);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:13,代码来源:CheckingInvalidationListener.java
示例7: informError
import com.google.ipc.invalidation.ticl.Statistics.ListenerEventType; //导入依赖的package包/类
@Override
public void informError(final InvalidationClient client, final ErrorInfo errorInfo) {
Preconditions.checkState(internalScheduler.isRunningOnThread(), "Not on internal thread");
listenerScheduler.schedule(NO_DELAY, new NamedRunnable("CheckingInvalListener.informError") {
@Override
public void run() {
statistics.recordListenerEvent(ListenerEventType.INFORM_ERROR);
delegate.informError(client, errorInfo);
}
});
}
开发者ID:mogoweb,项目名称:365browser,代码行数:12,代码来源:CheckingInvalidationListener.java
注:本文中的com.google.ipc.invalidation.ticl.Statistics.ListenerEventType类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论