hazelcast-all-3.2.5.jar
登录
|
com.hazelcast:hazelcast-all:3.2.5
META-INF
com
hazelcast
queue
nio
core
spring
query
config
partition
mapreduce
aws
security
web
monitor
examples
transaction
wan
util
map
storage
osgi
spi
topic
multimap
cluster
instance
executor
collection
ascii
client
DistributedObjectListenerRequest.java
ClientRequest.java
LifecycleServiceImpl.java
GenericError.java
HazelcastClientProxy.java
ClientServiceProxy.java
CallableClientRequest.java
PartitionClientRequest.java
KeyBasedClientRequest.java
ClientPrincipal.java
package-info.java
DistributedObjectInfo.java
ClientEndpoint.java
AuthenticationException.java
config
GenericClientExceptionConverter.java
RetryableRequest.java
txn
TargetClientRequest.java
HazelcastClient.java
ClientOutOfMemoryHandler.java
SecureRequest.java
nearcache
proxy
HazelcastClientManagedContext.java
ClientEngine.java
MultiPartitionClientRequest.java
examples
ClientImpl.java
ClientPortableFactory.java
connection
ClientEngineImpl.java
GetDistributedObjectsRequest.java
util
ClientTypes.java
ClientDisconnectionOperation.java
InvocationClientRequest.java
JavaClientExceptionConverter.java
spi
ClientExceptionConverter.java
RemoveDistributedObjectListenerRequest.java
AuthenticationRequest.java
ClientDestroyRequest.java
AllPartitionsClientRequest.java
ClientReAuthOperation.java
ClientDataSerializerHook.java
ClientResponse.java
LoadBalancer.java
ClientPortableHook.java
BaseClientRemoveListenerRequest.java
MultiTargetClientRequest.java
ClientCreateRequest.java
ClientExceptionConverters.java
OperationFactoryWrapper.java
concurrent
logging
jmx
management
hibernate
server.bat
test.bat
hazelcast-download.properties
hazelcast-client-config-3.1.xsd
hazelcast-client-default.xml
hazelcast-default.xml
hazelcast-client-config-3.2.xsd
hazelcast-spring-3.1.xsd
run.sh
server.sh
hazelcast-common-config-3.1.xsd
hazelcast-fullconfig.xml
hazelcast-config-3.1.xsd
hazelcast-runtime.properties
run.bat
client.sh
hazelcast-spring-3.0.xsd
hazelcast-client-config-3.0.xsd
hazelcast-client-full.xml
hazelcast-common-config-3.0.xsd
test.sh
hazelcast-config-3.0.xsd
hazelcast-spring-3.2.xsd
hazelcast-config-3.2.xsd
DistributedObjectListenerRequest.java
清空
类结构
/* * Copyright (c) 2008-2013, Hazelcast, Inc. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package com.hazelcast.client; import com.hazelcast.core.
DistributedObjectEvent
; import com.hazelcast.core.
DistributedObjectListener
; import com.hazelcast.spi.
ProxyService
; import com.hazelcast.spi.impl.
PortableDistributedObjectEvent
; import java.security.
Permission
; public class
DistributedObjectListenerRequest
extends
CallableClientRequest
implements
RetryableRequest
{ public
DistributedObjectListenerRequest
() { } @
Override
public
Object
call
() throws
Exception
{
ProxyService
proxyService
=
clientEngine
.
getProxyService
();
String
registrationId
=
proxyService
.
addProxyListener
(new
MyDistributedObjectListener
());
endpoint
.
setDistributedObjectListener
(
registrationId
); return
registrationId
; } @
Override
public
String
getServiceName
() { return null; } @
Override
public int
getFactoryId
() { return
ClientPortableHook
.
ID
; } @
Override
public int
getClassId
() { return
ClientPortableHook
.
LISTENER
; } private class
MyDistributedObjectListener
implements
DistributedObjectListener
{ @
Override
public void
distributedObjectCreated
(
DistributedObjectEvent
event
) {
send
(
event
); } @
Override
public void
distributedObjectDestroyed
(
DistributedObjectEvent
event
) {
send
(
event
); } private void
send
(
DistributedObjectEvent
event
) { if (
endpoint
.
live
()) {
PortableDistributedObjectEvent
portableEvent
= new
PortableDistributedObjectEvent
(
event
.
getEventType
(),
event
.
getDistributedObject
().
getName
(),
event
.
getServiceName
());
endpoint
.
sendEvent
(
portableEvent
,
getCallId
()); } } } @
Override
public
Permission
getRequiredPermission
() { return null; } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口