Remove notion of XACommand

community/kernel/src/main/java/org/neo4j/kernel/impl/transaction/log/PhysicalTransactionCursor.java

@@ -92,7 +92,7 @@ public boolean next() throws IOException
                 }
 
                 LogEntryCommand command = entry.as();
-                entries.add( command.getXaCommand() );
+                entries.add( command.getCommand() );
             }
 
             PhysicalTransactionRepresentation transaction = new PhysicalTransactionRepresentation( entries );

community/kernel/src/main/java/org/neo4j/kernel/impl/transaction/log/entry/LogEntryCommand.java

@@ -39,7 +39,7 @@ public LogEntryCommand( LogEntryVersion version, StorageCommand command )
         this.command = command;
     }
 
-    public StorageCommand getXaCommand()
+    public StorageCommand getCommand()
     {
         return command;
     }

community/kernel/src/test/java/org/neo4j/kernel/impl/transaction/PhysicalTransactionCursorTest.java

@@ -115,7 +115,7 @@ public void shouldCallTheVisitorWithTheFoundTransaction() throws IOException
 
         // then
         PhysicalTransactionRepresentation txRepresentation =
-                new PhysicalTransactionRepresentation( singletonList( A_COMMAND_ENTRY.getXaCommand() ) );
+                new PhysicalTransactionRepresentation( singletonList( A_COMMAND_ENTRY.getCommand() ) );
         assertEquals(
                 new CommittedTransactionRepresentation( A_START_ENTRY, txRepresentation, A_COMMIT_ENTRY ),
                 cursor.get()
@@ -136,7 +136,7 @@ public void shouldSkipCheckPoints() throws IOException
 
         // then
         PhysicalTransactionRepresentation txRepresentation =
-                new PhysicalTransactionRepresentation( singletonList( A_COMMAND_ENTRY.getXaCommand() ) );
+                new PhysicalTransactionRepresentation( singletonList( A_COMMAND_ENTRY.getCommand() ) );
         assertEquals(
                 new CommittedTransactionRepresentation( A_START_ENTRY, txRepresentation, A_COMMIT_ENTRY ),
                 cursor.get()

community/kernel/src/test/java/org/neo4j/kernel/impl/transaction/state/LogTruncationTest.java

@@ -199,7 +199,7 @@ private void assertHandlesLogTruncation( Command cmd ) throws IOException
         try
         {
             LogEntry logEntry = logEntryReader.readLogEntry( inMemoryChannel );
-            StorageCommand command = ((LogEntryCommand) logEntry).getXaCommand();
+            StorageCommand command = ((LogEntryCommand) logEntry).getCommand();
             assertEquals( cmd, command );
         }
         catch ( Exception e )

community/kernel/src/test/java/org/neo4j/test/mockito/matcher/LogMatchers.java

@@ -201,7 +201,7 @@ public boolean matchesSafely( LogEntryCommand commandEntry )
                     return false;
                 }
 
-                Command command = (Command) commandEntry.getXaCommand();
+                Command command = (Command) commandEntry.getCommand();
                 return command.getKey() == key &&
                         command.getClass().equals( commandClass );
             }

community/lucene-index/src/test/java/org/neo4j/index/impl/lucene/explicit/IndexCreationTest.java

@@ -156,7 +156,7 @@ private void verifyThatIndexCreationTransactionIsTheFirstOne() throws Exception
 
                 if ( startFound && entry instanceof LogEntryCommand )
                 {
-                    commandsInFirstEntry.add( entry.<LogEntryCommand>as().getXaCommand() );
+                    commandsInFirstEntry.add( entry.<LogEntryCommand>as().getCommand() );
                 }
 
                 if ( entry instanceof LogEntryCommit )

enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/core/state/machines/token/ReplicatedTokenRequestSerializer.java

@@ -130,7 +130,7 @@ static Collection<StorageCommand> extractCommands( byte[] commandBytes )
         {
             while ( (entryRead = (LogEntryCommand) reader.readLogEntry( channel )) != null )
             {
-                commands.add( entryRead.getXaCommand() );
+                commands.add( entryRead.getCommand() );
             }
         }
         catch ( IOException e )

enterprise/causal-clustering/src/main/java/org/neo4j/causalclustering/core/state/machines/tx/ReplicatedTransactionFactory.java

@@ -156,7 +156,7 @@ public static TransactionRepresentation read( NetworkReadableClosableChannelNett
 
         while ( (entryRead = (LogEntryCommand) reader.readLogEntry( channel )) != null )
         {
-            commands.add( entryRead.getXaCommand() );
+            commands.add( entryRead.getCommand() );
         }
 
         PhysicalTransactionRepresentation tx = new PhysicalTransactionRepresentation( commands );

enterprise/causal-clustering/src/test/java/org/neo4j/causalclustering/catchup/tx/TxPullResponseEncodeDecodeTest.java

@@ -63,7 +63,7 @@ private CommittedTransactionRepresentation newCommittedTransactionRepresentation
                 new Command.NodeCommand( new NodeRecord( arbitraryRecordId ), new NodeRecord( arbitraryRecordId ) );
 
         PhysicalTransactionRepresentation physicalTransactionRepresentation =
-                new PhysicalTransactionRepresentation( singletonList( new LogEntryCommand( command ).getXaCommand() ) );
+                new PhysicalTransactionRepresentation( singletonList( new LogEntryCommand( command ).getCommand() ) );
         physicalTransactionRepresentation.setHeader( new byte[]{}, 0, 0, 0, 0, 0, 0 );
 
         LogEntryStart startEntry = new LogEntryStart( 0, 0, 0L, 0L, new byte[]{}, LogPosition.UNSPECIFIED );

enterprise/com/src/main/java/org/neo4j/com/Protocol.java

@@ -90,7 +90,7 @@ public TransactionRepresentation read( ChannelBuffer buffer, ByteBuffer temporar
             List<StorageCommand> commands = new LinkedList<>();
             while ( (entryRead = (LogEntryCommand) reader.readLogEntry( channel )) != null )
             {
-                commands.add( entryRead.getXaCommand() );
+                commands.add( entryRead.getCommand() );
             }
 
             PhysicalTransactionRepresentation toReturn = new PhysicalTransactionRepresentation( commands );

tools/src/main/java/org/neo4j/tools/dump/DumpLogicalLog.java

@@ -44,6 +44,7 @@
 import org.neo4j.storageengine.api.StorageCommand;
 import org.neo4j.tools.dump.TransactionLogAnalyzer.Monitor;
 import org.neo4j.tools.dump.inconsistency.ReportInconsistencies;
+
 import static java.util.TimeZone.getTimeZone;
 import static org.neo4j.helpers.Format.DEFAULT_TIME_ZONE;
 
@@ -153,7 +154,7 @@ private boolean matches( LogEntry logEntry )
         {
             if ( logEntry instanceof LogEntryCommand )
             {
-                if ( matches( ((LogEntryCommand)logEntry).getXaCommand() ) )
+                if ( matches( ((LogEntryCommand)logEntry).getCommand() ) )
                 {
                     return true;
                 }

tools/src/main/java/org/neo4j/tools/txlog/CheckTxLogs.java

@@ -207,7 +207,7 @@ private <C extends Command, R extends AbstractBaseRecord> boolean scan( Physical
                 LogEntry entry = logEntryCursor.get();
                 if ( entry instanceof LogEntryCommand )
                 {
-                    StorageCommand command = ((LogEntryCommand) entry).getXaCommand();
+                    StorageCommand command = ((LogEntryCommand) entry).getCommand();
                     if ( check.commandClass().isInstance( command ) )
                     {
                         long logVersion = logEntryCursor.getCurrentLogVersion();

tools/src/test/java/org/neo4j/tools/dump/TransactionLogAnalyzerTest.java

@@ -232,7 +232,7 @@ private static void assertTransaction( LogEntry[] transactionEntries, long expec
         assertTrue( Arrays.toString( transactionEntries ), transactionEntries[0] instanceof LogEntryStart );
         assertTrue( transactionEntries[1] instanceof LogEntryCommand );
         LogEntryCommand command = transactionEntries[1].as();
-        assertEquals( expectedId, ((Command.NodeCommand)command.getXaCommand()).getKey() );
+        assertEquals( expectedId, ((Command.NodeCommand)command.getCommand()).getKey() );
         assertTrue( transactionEntries[2] instanceof LogEntryCommit );
         LogEntryCommit commit = transactionEntries[2].as();
         assertEquals( expectedId, commit.getTxId() );