Avoid too many return statements within this method.

Open

                return engine.createTopic(topic, partition);

Avoid too many return statements within this method.

Open

                return Collections.singletonList(target);

Avoid too many return statements within this method.

Open

        return Collections.emptyList();

Avoid too many return statements within this method.

Open

        return false;

Avoid too many return statements within this method.

Open

        return false;

Method write has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void write(Object o, @Nullable MediaType contentType, HttpOutputMessage outputMessage) throws HttpMessageNotWritableException, IOException {
        outputMessage.getHeaders().setContentType(TEXT_CONTENT);
        // this may be too late to validate because Spring RestController has already got the object
        SimpleObjectMapper mapper = SimpleMapper.getInstance().getSafeMapper(o.getClass().getTypeName());

• Read up
  Read up

Method removeExpiredStreams has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    public static void removeExpiredStreams() {
        PostOffice po = PostOffice.getInstance();
        Utility util = Utility.getInstance();
        long now = System.currentTimeMillis();
        List<String> list = new ArrayList<>(streams.keySet());

• Read up
  Read up

Method write has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    public void write(Object payload) throws IOException {
        if (payload == null) {
            // null payload means EOF
            close();
        } else {

• Read up
  Read up

Method getValidatedRoute has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    private String getValidatedRoute(String route) throws IOException {
        if (route == null) {
            throw new IOException("Missing service routing path");
        }
        // guarantee that only valid service name is registered

• Read up
  Read up

Method load has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public List<PropertySource<?>> load(String name, Resource resource) {
        if (!ClassUtils.isPresent("org.yaml.snakeyaml.Yaml", getClass().getClassLoader())) {
            throw new IllegalStateException(
                    "Attempted to load " + name + " but snakeyaml was not found on the classpath");

• Read up
  Read up

Method validArgument has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    private boolean validArgument(String arg) {
        if (arg.startsWith("{") && arg.endsWith("}")) {
            String v = arg.substring(1, arg.length()-1);
            if (v.length() == 0) {
                return false;

• Read up
  Read up

Method write has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void write(Object o, @Nullable MediaType contentType, HttpOutputMessage outputMessage)
            throws HttpMessageNotWritableException, IOException {
        outputMessage.getHeaders().setContentType(JSON);
        // this may be too late to validate because Spring RestController has already got the object

• Read up
  Read up

Method setResponseHeaders has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    private void setResponseHeaders(EventEnvelope event, HttpHeaders headers) {
        for (String h: headers.keySet()) {
            /*
             * Except "set-cookie" that allows multiples,
             * all other headers are set as single value.

• Read up
  Read up

Method cleanUp has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    public void cleanUp() {
        long now = System.currentTimeMillis();
        log.debug("Cleaning up {}", this.getName());
        // clean up cache
        List<String> expired = new ArrayList<>();

• Read up
  Read up

Method enforceKeysAsText has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings({"rawtypes", "unchecked"})
    private void enforceKeysAsText(Map raw) {
        Set keys = new HashSet(raw.keySet());
        for (Object k: keys) {
            Object v = raw.get(k);

• Read up
  Read up

Method get has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    public Object get(String key) {
        TimedItem item = cache.get(key);
        if (item == null) {
            return null;
        } else {

• Read up
  Read up

Method exists has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    public boolean exists(String... routes) {
        if (routes == null || routes.length == 0) {
            return false;
        }
        if (routes.length == 1) {

• Read up
  Read up

Method getFlatList has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @SuppressWarnings("unchecked")
    private void getFlatList(String prefix, List<Object> src, Map<String, Object> target) {
        int n = 0;
        for (Object v: src) {
            String key = prefix+"["+n+"]";

• Read up
  Read up

Method getException has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    public Throwable getException() {
        if (!exRestored) {
            if (exceptionBytes != null) {
                try (ObjectInputStream in = new ObjectInputStream(new ByteArrayInputStream(exceptionBytes))) {
                    exception = (Throwable) in.readObject();

• Read up
  Read up

Method handle has a Cognitive Complexity of 6 (exceeds 5 allowed). Consider refactoring.

Open

    @Override
    public void handle(ServerWebSocket ws) {
        String uri = ws.path().trim();
        String path = findPath(uri);
        if (path == null) {

• Read up
  Read up