diff --git a/gradle.properties b/gradle.properties index 8f4b8954..5083ea53 100644 --- a/gradle.properties +++ b/gradle.properties @@ -1,2 +1,2 @@ # Only update version on publishing to Maven Central -version=1.7.3 +version=1.7.4 diff --git a/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/AbstractNetherNetXboxSignaling.java b/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/AbstractNetherNetXboxSignaling.java index dde7b095..98cab7aa 100644 --- a/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/AbstractNetherNetXboxSignaling.java +++ b/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/AbstractNetherNetXboxSignaling.java @@ -194,6 +194,12 @@ public void channelInactive(ChannelHandlerContext ctx) throws Exception { super.channelInactive(ctx); } + @Override + public boolean isActive() { + Channel ch = this.channel; + return ch != null && ch.isActive(); + } + @Override public void close() { if (channel != null) channel.close(); diff --git a/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetDiscoverySignaling.java b/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetDiscoverySignaling.java index 16479d08..a0b36341 100644 --- a/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetDiscoverySignaling.java +++ b/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetDiscoverySignaling.java @@ -164,6 +164,11 @@ public void setNotFoundHandler(NetherNetClientSignaling.NotFoundHandler handler) // Not implemented for Discovery signaling } + @Override + public boolean isActive() { + return this.discovery.isActive(); + } + @Override public void close() { this.discovery.close(); diff --git a/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetSignaling.java b/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetSignaling.java index fe63d3bb..dcaae658 100644 --- a/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetSignaling.java +++ b/transport-nethernet/src/main/java/dev/kastle/netty/channel/nethernet/signaling/NetherNetSignaling.java @@ -33,6 +33,11 @@ public interface NetherNetSignaling extends AutoCloseable { */ String getLocalNetworkId(); + /** + * Whether the signaling is connected and able to carry messages + */ + boolean isActive(); + /** * Closes the signaling channel and releases any associated resources. */