#1925

Committed 20 Mar 2025 03:46PM UTC coverage: 95.662% (-0.3%) from 95.95%

Build # #1925

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #1239 from nats-io/main-2-11

Main for server v2.11

Run Details

179 of 219 new or added lines in 15 files covered. (81.74%)

2 existing lines in 2 files now uncovered.

11600 of 12126 relevant lines covered (95.66%)

0.96 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/src/main/java/io/nats/client/impl/ReaderListenerConsoleImpl.java

// Copyright 2024 The NATS Authors
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at:
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

package io.nats.client.impl;

import io.nats.client.Message;
import io.nats.client.ReadListener;

public class ReaderListenerConsoleImpl implements ReadListener {
    @Override
    public void protocol(String op, String string) {
        System.out.println("RL/Protocol " + op + " " + string);
    }

    @Override
    public void message(String op, Message message) {
        String text = op + " " + message.getSubject() + " " + message.getReplyTo() + " " +
            (message.getData() == null ? "<no data>" : "data length: " + message.getData().length);
        if (message.isJetStream()) {
            System.out.println("RL/JS-Message " + text);
        }
        else {
            System.out.println("RL/Message " + text);
        }
    }
}

1	// Copyright 2024 The NATS Authors
2	// Licensed under the Apache License, Version 2.0 (the "License");
3	// you may not use this file except in compliance with the License.
4	// You may obtain a copy of the License at:
5	//
6	// http://www.apache.org/licenses/LICENSE-2.0
7	//
8	// Unless required by applicable law or agreed to in writing, software
9	// distributed under the License is distributed on an "AS IS" BASIS,
10	// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11	// See the License for the specific language governing permissions and
12	// limitations under the License.
13
14	package io.nats.client.impl;
15
16	import io.nats.client.Message;
17	import io.nats.client.ReadListener;
18
NEW 19	public class ReaderListenerConsoleImpl implements ReadListener {	×
20	@Override
21	public void protocol(String op, String string) {
NEW 22	System.out.println("RL/Protocol " + op + " " + string);	×
NEW 23	}	×
24
25	@Override
26	public void message(String op, Message message) {
NEW 27	String text = op + " " + message.getSubject() + " " + message.getReplyTo() + " " +	×
NEW 28	(message.getData() == null ? "<no data>" : "data length: " + message.getData().length);	×
NEW 29	if (message.isJetStream()) {	×
NEW 30	System.out.println("RL/JS-Message " + text);	×
31	}
32	else {
NEW 33	System.out.println("RL/Message " + text);	×
34	}
NEW 35	}	×
36	}

nats-io / nats.java / #1925

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous