Add MarshallableIn to WireIn and MarshallableOut to WireOut

OpenHFT · May 17, 2017 · deac380 · deac380
1 parent 5fad0a4
commit deac380
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/main/java/net/openhft/chronicle/queue/ExcerptAppender.java b/src/main/java/net/openhft/chronicle/queue/ExcerptAppender.java
@@ -89,7 +89,7 @@ default void pretouch() {
      */
     void padToCacheAlign(Padding padToCacheAlign);
 
-    Padding padToCacheAlign();
+    Padding padToCacheAlignMode();
 
     /**
      * Set whether to trigger indexing.

diff --git a/src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueExcerpts.java b/src/main/java/net/openhft/chronicle/queue/impl/single/SingleChronicleQueueExcerpts.java
@@ -93,7 +93,7 @@ static class StoreAppender implements ExcerptAppender, ExcerptContext, InternalA
             context = new StoreAppenderContext();
         }
 
-        public Padding padToCacheAlign() {
+        public Padding padToCacheAlignMode() {
             return padToCacheLines;
         }
 
@@ -116,7 +116,7 @@ public void padToCacheAlign(Padding padToCacheLines) {
         public void writeBytes(@NotNull WriteBytesMarshallable marshallable) throws UnrecoverableTimeoutException {
             try (DocumentContext dc = writingDocument()) {
                 marshallable.writeMarshallable(dc.wire().bytes());
-                if (padToCacheAlign() != Padding.ALWAYS)
+                if (padToCacheAlignMode() != Padding.ALWAYS)
                     ((StoreAppenderContext) dc).padToCacheAlign = false;
             }
         }
@@ -126,7 +126,7 @@ public void writeText(CharSequence text) throws UnrecoverableTimeoutException {
             try (DocumentContext dc = writingDocument()) {
                 dc.wire().bytes()
                         .append8bit(text);
-                if (padToCacheAlign() != Padding.ALWAYS)
+                if (padToCacheAlignMode() != Padding.ALWAYS)
                     ((StoreAppenderContext) dc).padToCacheAlign = false;
             }
         }
@@ -284,7 +284,7 @@ public DocumentContext writingDocument(boolean metaData) throws UnrecoverableTim
                         position(pos);
                         context.isClosed = false;
                         context.wire = wire;
-                        context.padToCacheAlign = padToCacheAlign() != Padding.NEVER;
+                        context.padToCacheAlign = padToCacheAlignMode() != Padding.NEVER;
                         context.metaData(metaData);
                         ok = true;
                         return context;