<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
- <version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
- <version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-annotations</artifactId>
- <version>${jackson.version}</version>
<scope>test</scope>
</dependency>
*/
package org.opendaylight.groupbasedpolicy.renderer;
-import org.opendaylight.groupbasedpolicy.renderer.lib.jsonrpc.JsonRpcEndpoint;
-
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelFutureListener;
public class InvalidEncodingException extends RuntimeException {
+ private static final long serialVersionUID = -2241512201890075052L;
private final String actual;
public InvalidEncodingException(String actual, String message) {
}
}
-
- private void print(ByteBuf buf, String message) {
- print(buf, buf.readerIndex(), buf.readableBytes(), message == null ? "buff" : message);
- }
-
- private void print(ByteBuf buf, int startPos, int chars, String message) {
- if (null == message) message = "";
- if (startPos > buf.writerIndex()) {
- logger.trace("startPos out of bounds");
- }
- byte[] b = new byte[startPos + chars <= buf.writerIndex() ? chars : buf.writerIndex() - startPos];
- buf.getBytes(startPos, b);
- logger.trace("{} ={}", message, new String(b));
- }
-
// copied from Netty decoder
private void fail(ChannelHandlerContext ctx, long frameLength) {
if (frameLength > 0) {
import java.util.Collections;
import java.util.List;
-import java.util.Map;
import java.util.Set;
import java.util.concurrent.atomic.AtomicReference;
import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.tenants.tenant.contract.subject.Rule;
import com.google.common.collect.ComparisonChain;
-import com.google.common.collect.ImmutableSet;
import com.google.common.collect.Ordering;
import com.google.common.collect.Table;
package org.opendaylight.groupbasedpolicy.renderer.lib.jsonrpc;
import static io.netty.buffer.Unpooled.copiedBuffer;
-import static org.junit.Assert.assertTrue;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.fail;
-
import io.netty.channel.embedded.EmbeddedChannel;
-import com.fasterxml.jackson.databind.DeserializationFeature;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.annotation.JsonIgnore;
-import com.fasterxml.jackson.databind.annotation.JsonDeserialize;
import com.fasterxml.jackson.databind.JsonNode;