You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by lq...@apache.org on 2017/03/31 13:38:45 UTC
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...
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