Re: Ignite service method cannot invoke for third time

[arunkjn]

Hi Dmitry,

Sorry I don't understand what you mean. Do you mean to do this-

    static EntryProcessor workflowStartProcessor = new EntryProcessor<Long,
Workflow, Object>() {
        @Override
        public Object process(MutableEntry<Long, Workflow> entry, Object...
arguments) throws EntryProcessorException {
            System.out.println("EntryProcessor started");
            Workflow w = entry.getValue();

            if (!w.getStatus().equals(Constants.WorkflowStatus.STOPPED))
                throw new EntryProcessorException("Workflow not in stopped
state");

            w.setStatus(Constants.WorkflowStatus.RUNNING);

            entry.setValue(w);

            return null;
        }
    };

    @Override
    public void startWorkflow(Long id) {
        System.out.println("trying to start service");


        // try to use lock key here
        workflowIgniteCache.invoke(id, workflowStartProcessor);

        System.out.println("Sending init events");
        sendInitEvents(workflowIgniteCache.get(id));
        System.out.println("Sent init events");
    }

I tried it but the same thing is happening. Could you please point me to
some example where static inner class based EntryProcessor is used?




--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/