hazelcast-all-3.2.5.jar
登录
|
com.hazelcast:hazelcast-all:3.2.5
META-INF
com
hazelcast
queue
PollBackupOperation.java
DrainBackupOperation.java
ContainsOperation.java
QueueItem.java
QueueEventFilter.java
QueueService.java
proxy
QueueOperation.java
tx
RemoveBackupOperation.java
QueueEvent.java
QueueBackupAwareOperation.java
TxQueueItem.java
OfferOperation.java
CompareAndRemoveOperation.java
QueueContainer.java
IteratorOperation.java
AddAllBackupOperation.java
CompareAndRemoveBackupOperation.java
SizeOperation.java
QueuePortableHook.java
OfferBackupOperation.java
CheckAndEvictOperation.java
DrainOperation.java
QueueWaitNotifyKey.java
AddAllOperation.java
client
QueueDataSerializerHook.java
QueueReplicationOperation.java
PollOperation.java
QueueStoreWrapper.java
ClearBackupOperation.java
PeekOperation.java
RemoveOperation.java
ClearOperation.java
QueueEvictionProcessor.java
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
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
ClearOperation.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.queue; import com.hazelcast.core.
ItemEventType
; import com.hazelcast.nio.serialization.
Data
; import com.hazelcast.spi.
Notifier
; import com.hazelcast.spi.
Operation
; import com.hazelcast.spi.
WaitNotifyKey
; import java.util.
Map
; /** * @author ali 12/6/12 */ public class
ClearOperation
extends
QueueBackupAwareOperation
implements
Notifier
{ private
Map
<
Long
,
Data
>
dataMap
; public
ClearOperation
() { } public
ClearOperation
(
String
name
) { super(
name
); } public void
run
() {
dataMap
=
getOrCreateContainer
().
clear
();
response
= true; } public void
afterRun
() throws
Exception
{
getQueueService
().
getLocalQueueStatsImpl
(
name
).
incrementOtherOperations
(); for (
Data
data
:
dataMap
.
values
()) {
publishEvent
(
ItemEventType
.
REMOVED
,
data
); } } public
Operation
getBackupOperation
() { return new
ClearBackupOperation
(
name
,
dataMap
.
keySet
()); } public boolean
shouldBackup
() { return
Boolean
.
TRUE
.
equals
(!
dataMap
.
isEmpty
()); } public boolean
shouldNotify
() { return
Boolean
.
TRUE
.
equals
(!
dataMap
.
isEmpty
()); } public
WaitNotifyKey
getNotifiedKey
() { return
getOrCreateContainer
().
getOfferWaitNotifyKey
(); } public int
getId
() { return
QueueDataSerializerHook
.
CLEAR
; } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口