op.execute( ctx.getServiceConfiguration().getPartitionNexus(), ctx.getConfiguration().getStore() );
op.execute( ctx.getServiceConfiguration().getPartitionNexus(), ctx.getConfiguration().getStore(), ctx.getServiceConfiguration().getGlobalRegistries().getAttributeTypeRegistry() );
    private synchronized void onLogEntry( ReplicationContext ctx, LogEntryMessage message ) throws Exception    {        // Return error if other replica than what is in progress sends        // a log entry        if ( !ctx.getPeer().equals( replicaInTransaction ) )        {            ctx.getSession().write( new LogEntryAckMessage( message.getSequence(), Constants.NOT_OK ) );            return;        }        Operation op = message.getOperation();        LogEntryAckMessage ack = null;        try        {            op.execute( ctx.getServiceConfiguration().getPartitionNexus(), ctx.getConfiguration().getStore() );            ack = new LogEntryAckMessage( message.getSequence(), Constants.OK );        }        catch ( Exception e )        {            ack = new LogEntryAckMessage( message.getSequence(), Constants.NOT_OK );            throw e;        }        finally        {            ctx.getSession().write( ack );        }    }