test_class.declarator: exporter
test_class.modifier: private
test_class.original_string: private Exporter    exporter;
test_class.type: Exporter
test_class.var_name: exporter
test_class.declarator: store
test_class.modifier: private
test_class.original_string: private BlobStore   store;
test_class.type: BlobStore
test_class.var_name: store
test_class.declarator: ss
test_class.modifier: private
test_class.original_string: private ServerStore ss;
test_class.type: ServerStore
test_class.var_name: ss
test_class.declarator: cs
test_class.modifier: private
test_class.original_string: private ClientStore cs;
test_class.type: ClientStore
test_class.var_name: cs
test_class.file: akubra-rmi/src/test/java/org/akubraproject/rmi/client/ClientStoreTest.java
test_class.identifier: ClientStoreTest
test_case.body: @SuppressWarnings("unchecked")
    @Test
    public void testOpenConnection() throws IOException {
      BlobStoreConnection con = createMock(BlobStoreConnection.class);
      Transaction         tx  = createMock(Transaction.class);
  
      reset(store);
      makeThreadSafe(store, true);
      expect(store.openConnection(null, null)).andThrow(new UnsupportedOperationException());
      expect(store.openConnection(isA(ServerTransactionListener.class), (Map) isNull())).
          andReturn(con);
      replay(store);
  
      try {
        cs.openConnection(null, null);
        fail("Failed to rcv expected exception");
      } catch (UnsupportedOperationException e) {
      }
  
      BlobStoreConnection rc = cs.openConnection(tx, null);
      assertTrue(rc instanceof ClientConnection);
  
      verify(store);
    }
test_case.class_method_signature: ClientStoreTest.testOpenConnection()
test_case.full_signature: @SuppressWarnings("unchecked") @Test public void testOpenConnection()
test_case.identifier: testOpenConnection
test_case.invocations: createMock createMock reset makeThreadSafe andThrow expect openConnection andReturn expect openConnection isA isNull replay openConnection fail openConnection assertTrue verify
test_case.modifiers: @SuppressWarnings("unchecked") @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testOpenConnection()
focal_class.declarator: streamManager = new StreamManager()
focal_class.modifier: private final
focal_class.original_string: private final StreamManager streamManager = new StreamManager();
focal_class.type: StreamManager
focal_class.var_name: streamManager
focal_class.declarator: server
focal_class.modifier: private final
focal_class.original_string: private final RemoteStore   server;
focal_class.type: RemoteStore
focal_class.var_name: server
focal_class.file: akubra-rmi/src/main/java/org/akubraproject/rmi/client/ClientStore.java
focal_class.identifier: ClientStore
focal_class.class_method_signature: ClientStore.ClientStore(URI localId, RemoteStore server)
focal_class.full_signature: public  ClientStore(URI localId, RemoteStore server)
focal_class.identifier: ClientStore
focal_class.modifiers: public
focal_class.parameters: (URI localId, RemoteStore server)
focal_class.signature:  ClientStore(URI localId, RemoteStore server)
focal_class.class_method_signature: ClientStore.openConnection(Transaction tx, Map<String, String> hints)
focal_class.full_signature: @Override public BlobStoreConnection openConnection(Transaction tx, Map<String, String> hints)
focal_class.identifier: openConnection
focal_class.modifiers: @Override public
focal_class.parameters: (Transaction tx, Map<String, String> hints)
focal_class.return: BlobStoreConnection
focal_class.signature: BlobStoreConnection openConnection(Transaction tx, Map<String, String> hints)
focal_class.superclass: extends AbstractBlobStore
focal_method.body: @Override
    public BlobStoreConnection openConnection(Transaction tx, Map<String, String> hints)
                                       throws UnsupportedOperationException, IOException {
      RemoteConnection con = (tx == null) ? server.openConnection(hints)
          : new ClientTransactionListener(server.startTransactionListener(hints), tx).getConnection();
  
      return new ClientConnection(this, streamManager, con);
    }
focal_method.class_method_signature: ClientStore.openConnection(Transaction tx, Map<String, String> hints)
focal_method.full_signature: @Override public BlobStoreConnection openConnection(Transaction tx, Map<String, String> hints)
focal_method.identifier: openConnection
focal_method.invocations: openConnection getConnection startTransactionListener
focal_method.modifiers: @Override public
focal_method.parameters: (Transaction tx, Map<String, String> hints)
focal_method.return: BlobStoreConnection
focal_method.signature: BlobStoreConnection openConnection(Transaction tx, Map<String, String> hints)