[incubator-servicecomb-saga] 04/06: SCB-648 Update the omega-format modules
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit 1f19364309a9d7221d7eaef35e10e19e657434a6
Author: Willem Jiang
AuthorDate: Tue Jul 31 15:16:09 2018 +0800
SCB-648 Update the omega-format modules
---
.../apache/servicecomb/saga/omega/format/KryoMessageFormat.java| 7 ++-
.../servicecomb/saga/omega/format/MessageFormatTestBase.java | 5 -
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git
a/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
b/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
index f948963..50dfba8 100644
---
a/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
+++
b/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
@@ -32,7 +32,12 @@ public class KryoMessageFormat implements MessageFormat {
private static final int DEFAULT_BUFFER_SIZE = 4096;
- private static final KryoFactory factory = Kryo::new;
+ private static final KryoFactory factory = new KryoFactory() {
+@Override
+public Kryo create() {
+ return new Kryo();
+}
+ };
private static final KryoPool pool = new
KryoPool.Builder(factory).softReferences().build();
diff --git
a/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
b/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
index aab6ad7..904bd4c 100644
---
a/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
+++
b/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
@@ -25,7 +25,10 @@ import static org.hamcrest.Matchers.nullValue;
import static org.hamcrest.Matchers.startsWith;
import static org.junit.Assert.assertThat;
+import java.util.List;
+
import org.apache.servicecomb.saga.omega.transaction.OmegaException;
+import org.hamcrest.Matcher;
import org.junit.Ignore;
import org.junit.Test;
@@ -40,7 +43,7 @@ public class MessageFormatTestBase {
Object[] message = format.deserialize(bytes);
-assertThat(asList(message), contains("hello", "world"));
+assertThat(asList(message).containsAll(asList("hello", "world")),
is(true));
}
@Test
[incubator-servicecomb-saga] 04/06: SCB-648 Update the omega-format modules
This is an automated email from the ASF dual-hosted git repository.
ningjiang pushed a commit to branch SCB-648
in repository https://gitbox.apache.org/repos/asf/incubator-servicecomb-saga.git
commit 08682e9b736c9f6ebffbbce070ad027eabd58a3b
Author: Willem Jiang
AuthorDate: Tue Jul 31 15:16:09 2018 +0800
SCB-648 Update the omega-format modules
---
.../apache/servicecomb/saga/omega/format/KryoMessageFormat.java| 7 ++-
.../servicecomb/saga/omega/format/MessageFormatTestBase.java | 5 -
2 files changed, 10 insertions(+), 2 deletions(-)
diff --git
a/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
b/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
index f948963..50dfba8 100644
---
a/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
+++
b/omega/omega-format/src/main/java/org/apache/servicecomb/saga/omega/format/KryoMessageFormat.java
@@ -32,7 +32,12 @@ public class KryoMessageFormat implements MessageFormat {
private static final int DEFAULT_BUFFER_SIZE = 4096;
- private static final KryoFactory factory = Kryo::new;
+ private static final KryoFactory factory = new KryoFactory() {
+@Override
+public Kryo create() {
+ return new Kryo();
+}
+ };
private static final KryoPool pool = new
KryoPool.Builder(factory).softReferences().build();
diff --git
a/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
b/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
index aab6ad7..904bd4c 100644
---
a/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
+++
b/omega/omega-format/src/test/java/org/apache/servicecomb/saga/omega/format/MessageFormatTestBase.java
@@ -25,7 +25,10 @@ import static org.hamcrest.Matchers.nullValue;
import static org.hamcrest.Matchers.startsWith;
import static org.junit.Assert.assertThat;
+import java.util.List;
+
import org.apache.servicecomb.saga.omega.transaction.OmegaException;
+import org.hamcrest.Matcher;
import org.junit.Ignore;
import org.junit.Test;
@@ -40,7 +43,7 @@ public class MessageFormatTestBase {
Object[] message = format.deserialize(bytes);
-assertThat(asList(message), contains("hello", "world"));
+assertThat(asList(message).containsAll(asList("hello", "world")),
is(true));
}
@Test
