FazBrowse GitHub Viewer | Trending |
URL:
| Home
Tools: [Download Repo ZIP]   [Original HTTPS Page]

prepare for release · margrop/JavaNSQClient@ce2b1ed · GitHub

  1. margrop
  2. JavaNSQClient

Repository navigation

Commit ce2b1ed

Browse files
brainlag
committed
prepare for release
1 parent b88fb76 commit ce2b1ed

28 files changed

Lines changed: 90 additions & 82 deletions

‎pom.xml‎

Lines changed: 13 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@
44
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
55
<modelVersion>4.0.0</modelVersion>
66

7-
<groupId>io.nsq</groupId>
8-
<artifactId>client</artifactId>
7+
<groupId>com.github.brainlag.nsq</groupId>
8+
<artifactId>nsq-client</artifactId>
99
<version>1.0.0-SNAPSHOT</version>
1010

1111
<name>JavaNSQClient</name>
@@ -21,8 +21,6 @@
2121
<developer>
2222
<name>Peter Nimmervoll</name>
2323
<email>nimmervoll.peter@gmail.com</email>
24-
<organization>nsq</organization>
25-
<organizationUrl>nsq.io</organizationUrl>
2624
</developer>
2725
</developers>
2826
<scm>
@@ -95,6 +93,17 @@
9593
</profile>
9694
</profiles>
9795

96+
<distributionManagement>
97+
<snapshotRepository>
98+
<id>ossrh</id>
99+
<url>https://oss.sonatype.org/content/repositories/snapshots</url>
100+
</snapshotRepository>
101+
<repository>
102+
<id>ossrh</id>
103+
<url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
104+
</repository>
105+
</distributionManagement>
106+
98107
<dependencies>
99108
<dependency>
100109
<groupId>org.apache.logging.log4j</groupId>

src/main/java/io/nsq/Connection.java renamed to src/main/java/com/github/brainlag/nsq/Connection.java

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,14 @@
1-
package io.nsq;
2-
1+
package com.github.brainlag.nsq;
2+
3+
import com.github.brainlag.nsq.callbacks.NSQErrorCallback;
4+
import com.github.brainlag.nsq.callbacks.NSQMessageCallback;
5+
import com.github.brainlag.nsq.exceptions.NSQException;
6+
import com.github.brainlag.nsq.exceptions.NoConnectionsException;
7+
import com.github.brainlag.nsq.frames.ErrorFrame;
8+
import com.github.brainlag.nsq.frames.MessageFrame;
9+
import com.github.brainlag.nsq.frames.NSQFrame;
10+
import com.github.brainlag.nsq.frames.ResponseFrame;
11+
import com.github.brainlag.nsq.netty.NSQClientInitializer;
312
import io.netty.bootstrap.Bootstrap;
413
import io.netty.buffer.ByteBuf;
514
import io.netty.buffer.Unpooled;
@@ -9,15 +18,6 @@
918
import io.netty.channel.nio.NioEventLoopGroup;
1019
import io.netty.channel.socket.nio.NioSocketChannel;
1120
import io.netty.util.AttributeKey;
12-
import io.nsq.callbacks.NSQErrorCallback;
13-
import io.nsq.callbacks.NSQMessageCallback;
14-
import io.nsq.exceptions.NSQException;
15-
import io.nsq.exceptions.NoConnectionsException;
16-
import io.nsq.frames.ErrorFrame;
17-
import io.nsq.frames.MessageFrame;
18-
import io.nsq.frames.NSQFrame;
19-
import io.nsq.frames.ResponseFrame;
20-
import io.nsq.netty.NSQClientInitializer;
2121
import org.apache.logging.log4j.LogManager;
2222

2323
import java.net.InetSocketAddress;

src/main/java/io/nsq/NSQCommand.java renamed to src/main/java/com/github/brainlag/nsq/NSQCommand.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.nsq;
1+
package com.github.brainlag.nsq;
22

33
import java.util.ArrayList;
44
import java.util.List;

src/main/java/io/nsq/NSQConfig.java renamed to src/main/java/com/github/brainlag/nsq/NSQConfig.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.nsq;
1+
package com.github.brainlag.nsq;
22

33
import org.apache.logging.log4j.LogManager;
44

src/main/java/io/nsq/NSQConsumer.java renamed to src/main/java/com/github/brainlag/nsq/NSQConsumer.java

Lines changed: 9 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1,16 +1,15 @@
1-
package io.nsq;
2-
1+
package com.github.brainlag.nsq;
2+
3+
import com.github.brainlag.nsq.callbacks.NSQErrorCallback;
4+
import com.github.brainlag.nsq.callbacks.NSQMessageCallback;
5+
import com.github.brainlag.nsq.exceptions.NoConnectionsException;
6+
import com.github.brainlag.nsq.frames.ErrorFrame;
7+
import com.github.brainlag.nsq.frames.NSQFrame;
8+
import com.github.brainlag.nsq.lookup.NSQLookup;
39
import com.google.common.base.Throwables;
410
import com.google.common.collect.Maps;
511
import io.netty.bootstrap.Bootstrap;
6-
import io.nsq.callbacks.NSQErrorCallback;
7-
import io.nsq.callbacks.NSQMessageCallback;
8-
import io.nsq.exceptions.NoConnectionsException;
9-
import io.nsq.frames.ErrorFrame;
10-
import io.nsq.frames.NSQFrame;
11-
import io.nsq.lookup.NSQLookup;
1212
import org.apache.logging.log4j.LogManager;
13-
import sun.plugin.dom.exception.InvalidStateException;
1413

1514
import java.io.IOException;
1615
import java.util.*;
@@ -101,7 +100,7 @@ private void cleanClose() {
101100
if (frame instanceof ErrorFrame) {
102101
String err = ((ErrorFrame) frame).getErrorMessage();
103102
if (err.startsWith("E_INVALID")) {
104-
throw new InvalidStateException(err);
103+
throw new IllegalStateException(err);
105104
}
106105
}
107106
}

src/main/java/io/nsq/NSQMessage.java renamed to src/main/java/com/github/brainlag/nsq/NSQMessage.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.nsq;
1+
package com.github.brainlag.nsq;
22

33
import org.apache.logging.log4j.LogManager;
44

src/main/java/io/nsq/NSQProducer.java renamed to src/main/java/com/github/brainlag/nsq/NSQProducer.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
1-
package io.nsq;
2-
1+
package com.github.brainlag.nsq;
2+
3+
import com.github.brainlag.nsq.exceptions.BadMessageException;
4+
import com.github.brainlag.nsq.exceptions.BadTopicException;
5+
import com.github.brainlag.nsq.exceptions.NSQException;
6+
import com.github.brainlag.nsq.exceptions.NoConnectionsException;
7+
import com.github.brainlag.nsq.frames.ErrorFrame;
8+
import com.github.brainlag.nsq.frames.NSQFrame;
9+
import com.github.brainlag.nsq.pool.ConnectionPoolFactory;
310
import com.google.common.collect.Sets;
4-
import io.nsq.exceptions.BadMessageException;
5-
import io.nsq.exceptions.BadTopicException;
6-
import io.nsq.exceptions.NSQException;
7-
import io.nsq.exceptions.NoConnectionsException;
8-
import io.nsq.frames.ErrorFrame;
9-
import io.nsq.frames.NSQFrame;
10-
import io.nsq.pool.ConnectionPoolFactory;
1111
import org.apache.commons.pool2.impl.GenericKeyedObjectPool;
1212
import org.apache.commons.pool2.impl.GenericKeyedObjectPoolConfig;
1313

src/main/java/io/nsq/ServerAddress.java renamed to src/main/java/com/github/brainlag/nsq/ServerAddress.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package io.nsq;
1+
package com.github.brainlag.nsq;
22

33
import java.util.Objects;
44

‎src/main/java/com/github/brainlag/nsq/callbacks/NSQErrorCallback.java‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
package com.github.brainlag.nsq.callbacks;
2+
3+
import com.github.brainlag.nsq.exceptions.NSQException;
4+
5+
@FunctionalInterface
6+
public interface NSQErrorCallback {
7+
8+
void error(NSQException x);
9+
}

src/main/java/io/nsq/callbacks/NSQMessageCallback.java renamed to src/main/java/com/github/brainlag/nsq/callbacks/NSQMessageCallback.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
1-
package io.nsq.callbacks;
1+
package com.github.brainlag.nsq.callbacks;
22

3-
import io.nsq.NSQMessage;
3+
import com.github.brainlag.nsq.NSQMessage;
44

55
@FunctionalInterface
66
public interface NSQMessageCallback {

0 commit comments

Comments
 (0)
Back | FazBrowse Home | New Git URL