Hazelcast 地图条目侦听器不来自 Spring
Hazelcast map entry listener does not from Spring
我正在尝试配置 Hazelcast 地图以使用 Spring 的入口侦听器。但是,我发现它不起作用(事件没有传到侦听器)。
我的入口监听器:
public class MyMapListener extends EntryAdapter<String, String> implements MapListener{
@Override
public void onEntryEvent(EntryEvent<String, String> event) {
EntryEventType type = event.getEventType();
System.out.println("Event type: " + type);
}
}
我的 Spring 应用程序上下文:
<hz:hazelcast id="instance">
<hz:config>
<hz:group name="dev" password="password"/>
<hz:properties>
<hz:property name="hazelcast.merge.first.run.delay.seconds">5</hz:property>
<hz:property name="hazelcast.merge.next.run.delay.seconds">5</hz:property>
</hz:properties>
<hz:network port="5705" port-auto-increment="true">
<hz:join>
<hz:multicast enabled="true"/>
</hz:join>
</hz:network>
<hz:map name="myMap" >
<hz:entry-listeners>
<hz:entry-listener class-name="rw.gov.dgie.bms.hazelcast.listener.map.MyMapListener" include-value="true"/>
<hz:entry-listener implementation="myMapListener" local="true"/>
</hz:entry-listeners>
</hz:map>
</hz:config>
</hz:hazelcast>
<hz:client id="client">
<hz:group name="dev" password="password"/>
<hz:network>
<hz:member>127.0.0.1:5705</hz:member>
</hz:network>
</hz:client>
<bean class="rw.gov.dgie.bms.hazelcast.listener.map.MyMapListener" name="myMapListener"/>
<hz:map id="myMap" instance-ref="instance" name="MyMap" lazy-init="false"/>
当我将侦听器添加到从 Java 代码注入的地图时,它工作正常:
@Autowired
private IMap myMap;
myMap.addEntryListener((MapListener)new MyMapListener(), true);
我做错了什么?
改变
<hz:map id="myMap" instance-ref="instance" name="MyMap" lazy-init="false"/>
至
<hz:map id="myMap" instance-ref="instance" name="myMap" lazy-init="false"/>
id
是bean的名字,name
是map的名字。
在原代码的顶部,这里是监听器
<hz:map name="myMap">
<hz:entry-listeners>
被添加到名为“myMap”的地图,底部的 bean 引用名为“MyMap”的地图。由于 M 的大写在一张而不是另一张上,所以两张不同的地图。
我正在尝试配置 Hazelcast 地图以使用 Spring 的入口侦听器。但是,我发现它不起作用(事件没有传到侦听器)。
我的入口监听器:
public class MyMapListener extends EntryAdapter<String, String> implements MapListener{
@Override
public void onEntryEvent(EntryEvent<String, String> event) {
EntryEventType type = event.getEventType();
System.out.println("Event type: " + type);
}
}
我的 Spring 应用程序上下文:
<hz:hazelcast id="instance">
<hz:config>
<hz:group name="dev" password="password"/>
<hz:properties>
<hz:property name="hazelcast.merge.first.run.delay.seconds">5</hz:property>
<hz:property name="hazelcast.merge.next.run.delay.seconds">5</hz:property>
</hz:properties>
<hz:network port="5705" port-auto-increment="true">
<hz:join>
<hz:multicast enabled="true"/>
</hz:join>
</hz:network>
<hz:map name="myMap" >
<hz:entry-listeners>
<hz:entry-listener class-name="rw.gov.dgie.bms.hazelcast.listener.map.MyMapListener" include-value="true"/>
<hz:entry-listener implementation="myMapListener" local="true"/>
</hz:entry-listeners>
</hz:map>
</hz:config>
</hz:hazelcast>
<hz:client id="client">
<hz:group name="dev" password="password"/>
<hz:network>
<hz:member>127.0.0.1:5705</hz:member>
</hz:network>
</hz:client>
<bean class="rw.gov.dgie.bms.hazelcast.listener.map.MyMapListener" name="myMapListener"/>
<hz:map id="myMap" instance-ref="instance" name="MyMap" lazy-init="false"/>
当我将侦听器添加到从 Java 代码注入的地图时,它工作正常:
@Autowired
private IMap myMap;
myMap.addEntryListener((MapListener)new MyMapListener(), true);
我做错了什么?
改变
<hz:map id="myMap" instance-ref="instance" name="MyMap" lazy-init="false"/>
至
<hz:map id="myMap" instance-ref="instance" name="myMap" lazy-init="false"/>
id
是bean的名字,name
是map的名字。
在原代码的顶部,这里是监听器
<hz:map name="myMap">
<hz:entry-listeners>
被添加到名为“myMap”的地图,底部的 bean 引用名为“MyMap”的地图。由于 M 的大写在一张而不是另一张上,所以两张不同的地图。