Examples of sendEvent()

Examples of com.corundumstudio.socketio.SocketIOClient.sendEvent()

89
90
91
92
93
94
95
96
97
98
99
          SocketIOClient client = userDetail.getSocketClient();
          if (client != null) {
            String event = remind.getStyleTyp().equals(
                RemindEnum.TEXT.getCode()) ? "textEvent"
                : "popUpEvent";
            client.sendEvent(event, data);
            logger.debug("remind item to user : "
                + remind.getScopePid() + " " + event + " send");
          }
        }
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

73
74
75
76
77
78
79
80
81
82
83
                if (endpoint.live()) {
                    Data key = clientEngine.toData(event.getKey());
                    Data value = clientEngine.toData(event.getValue());
                    Data oldValue = clientEngine.toData(event.getOldValue());
                    PortableEntryEvent portableEntryEvent = new PortableEntryEvent(key, value, oldValue, event.getEventType(), event.getMember().getUuid());
                    endpoint.sendEvent(portableEntryEvent, getCallId());
                }
            }

            public void entryAdded(EntryEvent<Object, Object> event) {
                handleEvent(event);
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

50
51
52
53
54
55
56
57
58
59
60
        final String registrationId = service.addMembershipListener(new MembershipListener() {
            @Override
            public void memberAdded(MembershipEvent membershipEvent) {
                if (endpoint.live()) {
                    final MemberImpl member = (MemberImpl) membershipEvent.getMember();
                    endpoint.sendEvent(new ClientMembershipEvent(member, MembershipEvent.MEMBER_ADDED), getCallId());
                }
            }

            @Override
            public void memberRemoved(MembershipEvent membershipEvent) {
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

58
59
60
61
62
63
64
65
66
67
68
            @Override
            public void memberRemoved(MembershipEvent membershipEvent) {
                if (endpoint.live()) {
                    final MemberImpl member = (MemberImpl) membershipEvent.getMember();
                    endpoint.sendEvent(new ClientMembershipEvent(member, MembershipEvent.MEMBER_REMOVED), getCallId());
                }
            }

            public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
                if (endpoint.live()) {
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

70
71
72
73
74
75
76
77
78
79
80
                    final String uuid = member.getUuid();
                    final MemberAttributeOperationType op = memberAttributeEvent.getOperationType();
                    final String key = memberAttributeEvent.getKey();
                    final Object value = memberAttributeEvent.getValue();
                    final MemberAttributeChange memberAttributeChange = new MemberAttributeChange(uuid, op, key, value);
                    endpoint.sendEvent(new ClientMembershipEvent(member, memberAttributeChange), getCallId());
                }
            }
        });

        final String name = ClusterServiceImpl.SERVICE_NAME;
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

46
47
48
49
50
51
52
53
54
55
56
        final String registrationId = service.addMembershipListener(new MembershipListener() {
            @Override
            public void memberAdded(MembershipEvent membershipEvent) {
                if (endpoint.live()) {
                    final MemberImpl member = (MemberImpl) membershipEvent.getMember();
                    endpoint.sendEvent(new ClientMembershipEvent(member, MembershipEvent.MEMBER_ADDED), getCallId());
                }
            }

            @Override
            public void memberRemoved(MembershipEvent membershipEvent) {
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

54
55
56
57
58
59
60
61
62
63
64
            @Override
            public void memberRemoved(MembershipEvent membershipEvent) {
                if (endpoint.live()) {
                    final MemberImpl member = (MemberImpl) membershipEvent.getMember();
                    endpoint.sendEvent(new ClientMembershipEvent(member, MembershipEvent.MEMBER_REMOVED), getCallId());
                }
            }

            public void memberAttributeChanged(MemberAttributeEvent memberAttributeEvent) {
                if (endpoint.live()) {
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

66
67
68
69
70
71
72
73
74
75
76
                    final String uuid = member.getUuid();
                    final MemberAttributeOperationType op = memberAttributeEvent.getOperationType();
                    final String key = memberAttributeEvent.getKey();
                    final Object value = memberAttributeEvent.getValue();
                    final MemberAttributeChange memberAttributeChange = new MemberAttributeChange(uuid, op, key, value);
                    endpoint.sendEvent(new ClientMembershipEvent(member, memberAttributeChange), getCallId());
                }
            }
        });

        final String name = ClusterServiceImpl.SERVICE_NAME;
View Full Code Here

Examples of com.hazelcast.client.ClientEndpoint.sendEvent()

79
80
81
82
83
84
85
86
87
88
89
                if (endpoint.live()) {
                    Data item = serializationService.toData(event.getItem());
                    final ItemEventType eventType = event.getEventType();
                    final String uuid = event.getMember().getUuid();
                    PortableItemEvent portableItemEvent = new PortableItemEvent(item, eventType, uuid);
                    endpoint.sendEvent(portableItemEvent, getCallId());
                }
            }
        };
        final EventService eventService = clientEngine.getEventService();
        final CollectionEventFilter filter = new CollectionEventFilter(includeValue);
View Full Code Here

Examples of com.sun.enterprise.admin.pluggable.RUExtensionFeature.sendEvent()

98
99
100
101
102
103
104
105
106
107
108
            // Even if dynamic reconfiguration is disabled send the events
            // when instances are enabled/disabled
            boolean sendCCEvent = false; //CCEvent -> Cluster Change Event
            RUExtensionFeature ruef = AdminService.getRUExtensionFeature();
            if (ruef != null)
                sendCCEvent = ruef.sendEvent(_event);

            // forwards the event if dynamic reconfiguration is enabled
            if ((config != null && (config.isDynamicReconfigurationEnabled() || sendCCEvent ))
                    || (_event instanceof CommandEvent)) {
                ServerRuntimeMBean sRuntime =
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.