Hi All,
Can any of you remember the reason for using a receiver queue in HA mode?
if (mode == Mode.HA) {
HAConfiguration haConfiguration =
EventReceiverServiceValueHolder.getEventManagementService()
.getManagementModeInfo().getHaConfiguration();
Lock readLock =
EventReceiverServiceValueHolder.getCarbonEventReceiverManagementService().getReadLock();
inputEventDispatcher = new QueueInputEventDispatcher(tenantId,
EventManagementUtil.constructEventSyncId(tenantId,
eventReceiverConfiguration.getEventReceiverName(),
Manager.ManagerType.Receiver),
readLock, exportedStreamDefinition,
haConfiguration.getEventSyncReceiverMaxQueueSizeInMb(),
haConfiguration.getEventSyncReceiverQueueSize());
inputEventDispatcher.setSendToOther(!isEventDuplicatedInCluster);
EventReceiverServiceValueHolder.getEventManagementService()
.registerEventSync((EventSync) inputEventDispatcher,
Manager.ManagerType.Receiver);
} else {
inputEventDispatcher = new InputEventDispatcher();
}
--
Thanks & regards,
Nirmal
Technical Lead, WSO2 Inc.
Mobile: +94715779733
Blog: http://nirmalfdo.blogspot.com/
_______________________________________________
Dev mailing list
[email protected]
http://wso2.org/cgi-bin/mailman/listinfo/dev
