remove pool objects and introduce poj_01 dependency (#85)

* remove pool objects and introduce poj_01 dependency

* replace anonymous impl. of PoolableSupplier with PoolableSupplierFake

* add missing license to PoolableSupplierFake

* update poj_01 to 3.0.0

* removed unnecessary PoolTest, as it is poj_01 responsibility now

Author: eemhu

pom.xml

@@ -21,15 +21,14 @@
     <maven.compiler.target>1.8</maven.compiler.target>
     <junit.version>5.10.0</junit.version>
     <teragrep.tls_01.version>0.7.1</teragrep.tls_01.version>
+    <teragrep.poj_01.version>3.0.0</teragrep.poj_01.version>
   </properties>
-
   <licenses>
     <license>
       <name>Apache License v2.0</name>
       <url>https://www.apache.org/licenses/LICENSE-2.0.txt</url>
     </license>
   </licenses>
-
   <developers>
     <developer>
       <name>Mikko Kortelainen</name>
@@ -38,14 +37,17 @@
       <organizationUrl>https://teragrep.com</organizationUrl>
     </developer>
   </developers>
-
   <scm>
     <connection>scm:git:https://github.com/teragrep/rlp_01.git</connection>
     <developerConnection>scm:git:[email protected]:teragrep/rlp_01.git</developerConnection>
     <url>https://github.com/teragrep/rlp_01/tree/master</url>
   </scm>
-
   <dependencies>
+    <dependency>
+      <groupId>com.teragrep</groupId>
+      <artifactId>poj_01</artifactId>
+      <version>${teragrep.poj_01.version}</version>
+    </dependency>
     <!-- tls-channel, without slf4j -->
     <dependency>
       <groupId>com.teragrep</groupId>
@@ -77,7 +79,6 @@
       <scope>test</scope>
     </dependency>
   </dependencies>
-
   <build>
     <directory>${project.basedir}/target</directory>
     <finalName>rlp_01</finalName>

src/main/java/com/teragrep/rlp_01/client/IManagedRelpConnection.java

@@ -16,14 +16,15 @@
  */
 package com.teragrep.rlp_01.client;
 
+
 import com.teragrep.rlp_01.RelpBatch;
-import com.teragrep.rlp_01.pool.Poolable;
+import com.teragrep.stb_01.Stubable;
 
+import java.io.Closeable;
 import java.io.IOException;
 
-public interface IManagedRelpConnection extends Poolable {
+public interface IManagedRelpConnection extends Stubable, Closeable {
     void reconnect();
-
     void connect() throws IOException;
     void forceReconnect();
     void ensureSent(byte[] bytes);

src/main/java/com/teragrep/rlp_01/client/SSLContextSupplier.java

@@ -16,7 +16,7 @@
  */
 package com.teragrep.rlp_01.client;
 
-import com.teragrep.rlp_01.pool.Stubable;
+import com.teragrep.stb_01.Stubable;
 
 import javax.net.ssl.SSLContext;
 import java.util.function.Supplier;

src/main/java/com/teragrep/rlp_01/pool/Pool.java

@@ -20,9 +20,11 @@
 import com.teragrep.net_01.eventloop.EventLoop;
 import com.teragrep.net_01.eventloop.EventLoopFactory;
 import com.teragrep.net_01.server.ServerFactory;
+import com.teragrep.poj_01.pool.Pool;
+import com.teragrep.poj_01.pool.PoolableSupplier;
+import com.teragrep.poj_01.pool.UnboundPool;
 import com.teragrep.rlp_01.RelpBatch;
-import com.teragrep.rlp_01.pool.Pool;
-import com.teragrep.rlp_01.pool.UnboundPool;
+import com.teragrep.rlp_01.pool.PoolableSupplierFake;
 import com.teragrep.rlp_03.frame.FrameDelegationClockFactory;
 import com.teragrep.rlp_03.frame.delegate.EventDelegate;
 import com.teragrep.rlp_03.frame.delegate.FrameDelegate;
@@ -136,7 +138,7 @@ public void testPooledConnections() {
 
         RelpConnectionFactory relpConnectionFactory = new RelpConnectionFactory(relpConfig);
 
-        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(relpConnectionFactory, new ManagedRelpConnectionStub());
+        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(new PoolableSupplierFake<>(c->Assertions.assertDoesNotThrow(c::close), p -> relpConnectionFactory.get()), new ManagedRelpConnectionStub());
 
         int testCycles = 1_000;
         CountDownLatch countDownLatch = new CountDownLatch(testCycles);
@@ -184,7 +186,7 @@ public void testPooledRenewedConnections() {
 
         RelpConnectionFactory relpConnectionFactory = new RelpConnectionFactory(relpConfig);
 
-        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(relpConnectionFactory, new ManagedRelpConnectionStub());
+        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(new PoolableSupplierFake<>(c->Assertions.assertDoesNotThrow(c::close), p -> relpConnectionFactory.get()), new ManagedRelpConnectionStub());
 
         int testCycles = 20;
         CountDownLatch countDownLatch = new CountDownLatch(testCycles);
@@ -241,7 +243,7 @@ public void testPooledReboundConnections() {
 
         RelpConnectionFactory relpConnectionFactory = new RelpConnectionFactory(relpConfig);
 
-        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(relpConnectionFactory, new ManagedRelpConnectionStub());
+        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(new PoolableSupplierFake<>(c->Assertions.assertDoesNotThrow(c::close), p -> relpConnectionFactory.get()), new ManagedRelpConnectionStub());
 
         int testCycles = 20;
         CountDownLatch countDownLatch = new CountDownLatch(testCycles);
@@ -297,7 +299,7 @@ public void testRelpBatchSend() {
 
         RelpConnectionFactory relpConnectionFactory = new RelpConnectionFactory(relpConfig);
 
-        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(relpConnectionFactory, new ManagedRelpConnectionStub());
+        Pool<IManagedRelpConnection> relpConnectionPool = new UnboundPool<>(new PoolableSupplierFake<>(c->Assertions.assertDoesNotThrow(c::close), p -> relpConnectionFactory.get()), new ManagedRelpConnectionStub());
 
         int testCycles = 20;
         CountDownLatch countDownLatch = new CountDownLatch(testCycles);