Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Main for server v2.11 #1239

Open
wants to merge 48 commits into
base: main
Choose a base branch
from
Open
Changes from 1 commit
Commits
Show all changes
48 commits
Select commit Hold shift + click to select a range
62a73b3
Direct Batch EOD and loop changes
scottf Oct 10, 2024
c83faff
Direct Batch EOD and loop changes
scottf Oct 10, 2024
aaecbff
Direct Batch EOD and loop changes
scottf Oct 10, 2024
1ee791b
Consumer Priority Group Overflow (#1233)
scottf Oct 10, 2024
ad60f23
Merge branch 'main' into main-2-11
scottf Oct 10, 2024
cfa5cbc
Merge branch 'main' into main-2-11
scottf Oct 10, 2024
3dbc5fb
Merge branch 'main' into main-2-11
scottf Oct 11, 2024
d4667b4
Merge branch 'main' into main-2-11
scottf Oct 15, 2024
2b21962
Merge branch 'main' into main-2-11
scottf Oct 18, 2024
93510f2
Refactoring based on testing
scottf Oct 18, 2024
6b8d3df
Removed debug
scottf Oct 21, 2024
ad6694b
Removed debug
scottf Oct 21, 2024
f32791d
Support setting [min] sequence when needed
scottf Oct 21, 2024
6b82bca
In progress waiting for server PR's
scottf Oct 28, 2024
aa97394
Merge branch 'main' into main-2-11
scottf Oct 31, 2024
9cf1e16
Merge branch 'main' into main-2-11
scottf Nov 1, 2024
788c160
Server main branch has all 2.11 features
scottf Nov 1, 2024
7a9e0a5
Merge branch 'main' into main-2-11
scottf Nov 1, 2024
e0df8c0
Fixing removal
scottf Nov 1, 2024
ed87573
MessageBatchGetRequest reform based on adr
scottf Nov 5, 2024
b7379bb
more testing
scottf Nov 5, 2024
e242724
multi last for with batch
scottf Nov 7, 2024
3bfa65c
Merge branch 'refs/heads/main' into main-2-11
scottf Nov 14, 2024
6e9c067
Merge branch 'main' into main-2-11
scottf Nov 14, 2024
c97c535
Added MessageInfo getMessage(String streamName, MessageGetRequest mes…
scottf Nov 15, 2024
151b309
Merge branch 'main' into main-2-11
scottf Nov 15, 2024
050f106
Merge branch 'main' into main-2-11
scottf Nov 15, 2024
9c13f6a
Merge branch 'main' into main-2-11
scottf Nov 22, 2024
6a405ba
Update Doc
scottf Nov 24, 2024
0318b12
tuned request message batch
scottf Nov 25, 2024
592f596
Merge branch 'main' into main-2-11
scottf Nov 26, 2024
96271a1
tuned request message batch
scottf Nov 26, 2024
0aeb173
Merge branch 'main' into main-2-11
scottf Dec 3, 2024
e37d659
Merge branch 'main' into main-2-11
scottf Dec 4, 2024
e34817a
Merge branch 'main' into main-2-11
scottf Dec 4, 2024
800a684
Merge branch 'main' into main-2-11
scottf Dec 18, 2024
c1d1b58
Merge branch 'main' into main-2-11
scottf Jan 6, 2025
6884f7e
Merge branch 'main' into main-2-11
scottf Jan 9, 2025
5108a14
Merge branch 'main' into main-2-11
scottf Jan 16, 2025
b2ca330
Removed Direct Batch to Orbit
scottf Feb 13, 2025
c371e64
Merge branch 'main' into main-2-11
scottf Feb 17, 2025
e95930a
Merge branch 'main' into main-2-11
scottf Feb 18, 2025
af57d78
Merge branch 'main' into main-2-11
scottf Feb 19, 2025
0b11ac0
Merge branch 'main' into main-2-11
scottf Feb 20, 2025
804808c
Add Message TTL Stream Configuration (#1280)
scottf Feb 24, 2025
2b795b0
Merge branch 'main' into main-2-11
scottf Feb 24, 2025
18d8a43
Merge branch 'main' into main-2-11
scottf Feb 25, 2025
8f3d5fc
Fix tests after merge
scottf Feb 25, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Added MessageInfo getMessage(String streamName, MessageGetRequest mes…
…sageGetRequest) back in
  • Loading branch information
scottf committed Nov 15, 2024
commit c97c535c60d327718dea1f0bc9374aeff1f5efaa
11 changes: 11 additions & 0 deletions src/main/java/io/nats/client/JetStreamManagement.java
Original file line number Diff line number Diff line change
@@ -261,6 +261,17 @@ public interface JetStreamManagement {
*/
MessageInfo getMessage(String streamName, long seq) throws IOException, JetStreamApiException;

/**
* Get MessageInfo for the message matching the {@link MessageGetRequest}.
* @param streamName the name of the stream.
* @param messageGetRequest the {@link MessageGetRequest} to get a message
* @return The MessageInfo
* @throws IOException covers various communication issues with the NATS
* server such as timeout or interruption
* @throws JetStreamApiException the request had an error related to the data
*/
MessageInfo getMessage(String streamName, MessageGetRequest messageGetRequest) throws IOException, JetStreamApiException;

/**
* Get MessageInfo for the last message of the subject.
* @param streamName the name of the stream.
Original file line number Diff line number Diff line change
@@ -278,6 +278,11 @@ public MessageInfo getMessage(String streamName, long seq) throws IOException, J
return _getMessage(streamName, MessageGetRequest.forSequence(seq));
}

@Override
public MessageInfo getMessage(String streamName, MessageGetRequest messageGetRequest) throws IOException, JetStreamApiException {
return _getMessage(streamName, messageGetRequest);
}

/**
* {@inheritDoc}
*/