qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lqu...@apache.org
Subject svn commit: r1789687 [2/2] - in /qpid/java/trunk/broker-plugins: amqp-1-0-bdb-store/src/main/java/org/apache/qpid/server/protocol/v1_0/store/bdb/ amqp-1-0-jdbc-store/src/main/java/org/apache/qpid/server/protocol/v1_0/store/jdbc/ amqp-1-0-protocol/src/m...
Date Fri, 31 Mar 2017 13:38:45 GMT
Modified: qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/store/LinkStoreTestCase.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/store/LinkStoreTestCase.java?rev=1789687&r1=1789686&r2=1789687&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/store/LinkStoreTestCase.java
(original)
+++ qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/test/java/org/apache/qpid/server/protocol/v1_0/store/LinkStoreTestCase.java
Fri Mar 31 13:38:45 2017
@@ -88,7 +88,7 @@ public abstract class LinkStoreTestCase
 
     public void testOpenAndLoad() throws Exception
     {
-        Collection<LinkDefinition> links = _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
+        Collection<LinkDefinition<Source, Target>> links = _linkStore.openAndLoad(new
LinkStoreUpdaterImpl());
         assertTrue("Unexpected links", links.isEmpty());
 
         try
@@ -101,7 +101,7 @@ public abstract class LinkStoreTestCase
             // pass
         }
 
-        LinkDefinition linkDefinition = createLinkDefinition("1", "test");
+        LinkDefinition<Source, Target> linkDefinition = createLinkDefinition("1", "test");
         _linkStore.saveLink(linkDefinition);
         _linkStore.close();
 
@@ -117,7 +117,7 @@ public abstract class LinkStoreTestCase
         _linkStore.close();
         try
         {
-            LinkDefinition linkDefinition = createLinkDefinition("1", "test");
+            LinkDefinition<Source, Target> linkDefinition = createLinkDefinition("1",
"test");
             _linkStore.saveLink(linkDefinition);
             fail("Saving link with close store should fail");
         }
@@ -130,7 +130,7 @@ public abstract class LinkStoreTestCase
     public void testSaveLink() throws Exception
     {
 
-        LinkDefinition linkDefinition = createLinkDefinition("1", "test");
+        LinkDefinition<Source, Target> linkDefinition = createLinkDefinition("1", "test");
         _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
         _linkStore.saveLink(linkDefinition);
         _linkStore.close();
@@ -145,10 +145,10 @@ public abstract class LinkStoreTestCase
             // pass
         }
 
-        Collection<LinkDefinition> links = _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
+        Collection<LinkDefinition<Source, Target>> links = _linkStore.openAndLoad(new
LinkStoreUpdaterImpl());
         assertEquals("Unexpected link number", 1, links.size());
 
-        LinkDefinition recoveredLink = links.iterator().next();
+        LinkDefinition<Source, Target> recoveredLink = links.iterator().next();
 
         assertEquals("Unexpected link name", linkDefinition.getName(), recoveredLink.getName());
         assertEquals("Unexpected container id", linkDefinition.getRemoteContainerId(), recoveredLink.getRemoteContainerId());
@@ -161,10 +161,10 @@ public abstract class LinkStoreTestCase
     {
         _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
 
-        LinkDefinition linkDefinition = createLinkDefinition("1", "test");
+        LinkDefinition<Source, Target> linkDefinition = createLinkDefinition("1", "test");
         _linkStore.saveLink(linkDefinition);
 
-        LinkDefinition linkDefinition2 = createLinkDefinition("2", "test2");
+        LinkDefinition<Source, Target> linkDefinition2 = createLinkDefinition("2",
"test2");
         _linkStore.saveLink(linkDefinition2);
 
         _linkStore.deleteLink(linkDefinition2);
@@ -180,10 +180,10 @@ public abstract class LinkStoreTestCase
             // pass
         }
 
-        Collection<LinkDefinition> links = _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
+        Collection<LinkDefinition<Source, Target>> links = _linkStore.openAndLoad(new
LinkStoreUpdaterImpl());
         assertEquals("Unexpected link number", 1, links.size());
 
-        LinkDefinition recoveredLink = links.iterator().next();
+        LinkDefinition<Source, Target> recoveredLink = links.iterator().next();
 
         assertEquals("Unexpected link name", linkDefinition.getName(), recoveredLink.getName());
         assertEquals("Unexpected container id", linkDefinition.getRemoteContainerId(), recoveredLink.getRemoteContainerId());
@@ -196,14 +196,14 @@ public abstract class LinkStoreTestCase
     {
         _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
 
-        LinkDefinition linkDefinition = createLinkDefinition("1", "test");
+        LinkDefinition<Source, Target> linkDefinition = createLinkDefinition("1", "test");
         _linkStore.saveLink(linkDefinition);
 
-        LinkDefinition linkDefinition2 = createLinkDefinition("2", "test2");
+        LinkDefinition<Source, Target> linkDefinition2 = createLinkDefinition("2",
"test2");
         _linkStore.saveLink(linkDefinition2);
 
         _linkStore.close();
-        Collection<LinkDefinition> links = _linkStore.openAndLoad(new LinkStoreUpdaterImpl());
+        Collection<LinkDefinition<Source, Target>> links = _linkStore.openAndLoad(new
LinkStoreUpdaterImpl());
         assertEquals("Unexpected link number", 2, links.size());
 
         _linkStore.delete();
@@ -216,7 +216,7 @@ public abstract class LinkStoreTestCase
 
     protected abstract void deleteLinkStore();
 
-    private LinkDefinitionImpl createLinkDefinition(final String remoteContainerId, final
String linkName)
+    private LinkDefinitionImpl<Source, Target> createLinkDefinition(final String remoteContainerId,
final String linkName)
     {
         return new LinkDefinitionImpl(remoteContainerId, linkName, Role.RECEIVER, _source,
_target);
     }



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message