Priyanka

You need to provide reproducer as a project or at least all logs and thread
dumps from all nodes, so somebody can help you.

Evgenii

2018-03-30 15:08 GMT+03:00 Priyanka Shinde <[email protected]>:

> Hi,
> Following is one of my cache configurations (we have same configuration for
> all 3 caches)
>
> CacheConfiguration<Integer, QueueGroup> queueGrpcfg= new
> CacheConfiguration<>("queueGrpCache");
>
> queueGrpcfg.setCacheMode(CacheMode.REPLICATED);
> queueGrpcfg.setAtomicityMode(CacheAtomicityMode.TRANSACTIONAL);
> queueGrpcfg.setIndexedTypes(Integer.class,QueueGroup.class);
> queueGrpcfg.setCopyOnRead(false);
> queueGrpcfg.setStoreKeepBinary(true);
> queueGrpcfg.setRebalanceMode(CacheRebalanceMode.SYNC);
> queueGrpcfg.setWriteSynchronizationMode(CacheWriteSynchronizationMode.
> FULL_SYNC);
>
> queueGrpcache = ignite.getOrCreateCache(queueGrpcfg);
>
> Member variables of QueueGroup Object :
>
> private int id;
>         private String name;
>         private int tenantGroupId;
>         private int qsThreadPriority;
>         private int qsSleepTime;
>         private int qaThreadPriority;
>         private int qaSleepTime;
>         private int maxRecords;
>         private float queryFactor;
>         private int minRecords;
>         private int scanDelay;
>         private int tsMaxTimerTasks;
>         private int tsMinTimeoutTime;
>         private int ronaScanDelay;
>         private int ronaMaxTimerTasks;
>         private int ronaMinTimeoutTime;
>         private int failureCount;
>         private String startTime;
>         private String endTime;
>         private boolean isRunningInNBH;
>         private Set<Integer> queueSet;
>         private boolean running = false;
>         private BusinessHoursController businessHoursController;
>         private ContactDAO contactDAO;
>         private QueueGroupStrategy strategy;
>         private static int queueTimeout = ServerProperties.
> getQueueTimeOutInMins();
>         private int calendarId;
>         private long lastBHEndTime;
>         private long lastBHStartTime;
>         private long lastOffsetUpdateTime;
>         private int maxSlaRecords;
>         private int channelId;
>
>
> During Initialization I put all the data in the cache.
> queueGrpcache.put(queueGrpId, QueueGroup Object)
>
> Also We have a multi-threaded application where we run thread per
> queuegroup
> in businesshours.
> Quick Response is really appreciated.
>
> Thanks and Regards,
> Priyanka
>
>
>
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>

Reply via email to