[jira] [Commented] (ARTEMIS-4825) EQ_UNUSUAL idempotent function
[
https://issues.apache.org/jira/browse/ARTEMIS-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856295#comment-17856295
]
Justin Bertram commented on ARTEMIS-4825:
-
Please do not set the "Component" field to {{ActiveMQ-Artemis-Native}} when the
issue has nothing to do with it.
> EQ_UNUSUAL idempotent function
> --
>
> Key: ARTEMIS-4825
> URL: https://issues.apache.org/jira/browse/ARTEMIS-4825
> Project: ActiveMQ Artemis
> Issue Type: Bug
>Affects Versions: 2.25.0
>Reporter: Andrey Slepykh
>Priority: Major
> Attachments: image-2024-06-19-18-15-06-497.png
>
>
> !image-2024-06-19-18-15-06-497.png!
> after overriding the
> [equals()|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/utils/SecurityManagerUtil.java#L61]
> method it always returns true
>
> Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE.
> Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Assigned] (ARTEMIS-4825) EQ_UNUSUAL idempotent function
[ https://issues.apache.org/jira/browse/ARTEMIS-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justin Bertram reassigned ARTEMIS-4825: --- Assignee: (was: Clebert Suconic) > EQ_UNUSUAL idempotent function > -- > > Key: ARTEMIS-4825 > URL: https://issues.apache.org/jira/browse/ARTEMIS-4825 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.25.0 >Reporter: Andrey Slepykh >Priority: Major > Attachments: image-2024-06-19-18-15-06-497.png > > > !image-2024-06-19-18-15-06-497.png! > after overriding the > [equals()|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/utils/SecurityManagerUtil.java#L61] > method it always returns true > > Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. > Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Updated] (ARTEMIS-4825) EQ_UNUSUAL idempotent function
[ https://issues.apache.org/jira/browse/ARTEMIS-4825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justin Bertram updated ARTEMIS-4825: Component/s: (was: ActiveMQ-Artemis-Native) > EQ_UNUSUAL idempotent function > -- > > Key: ARTEMIS-4825 > URL: https://issues.apache.org/jira/browse/ARTEMIS-4825 > Project: ActiveMQ Artemis > Issue Type: Bug >Affects Versions: 2.25.0 >Reporter: Andrey Slepykh >Assignee: Clebert Suconic >Priority: Major > Attachments: image-2024-06-19-18-15-06-497.png > > > !image-2024-06-19-18-15-06-497.png! > after overriding the > [equals()|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/utils/SecurityManagerUtil.java#L61] > method it always returns true > > Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. > Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Updated] (ARTEMIS-4824) code overload DM_BOXED_PRIMITIVE_FOR_PARSING
[ https://issues.apache.org/jira/browse/ARTEMIS-4824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrey Slepykh updated ARTEMIS-4824: Description: !image-2024-06-19-18-06-30-222.png! you are using the Integer.valueOf [in line 89|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L89] method which hashes the information, although ultimately the connectionCountThreshold variable is only used for comparison using the "if" on line [53|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L53] of the same file Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) was: !image-2024-06-19-18-06-30-222.png! you are using the ```Integer.valueOf``` [in line 89|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L89] method which hashes the information, although ultimately the connectionCountThreshold variable is only used for comparison using the "if" on line [53|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L53] of the same file Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) > code overload DM_BOXED_PRIMITIVE_FOR_PARSING > > > Key: ARTEMIS-4824 > URL: https://issues.apache.org/jira/browse/ARTEMIS-4824 > Project: ActiveMQ Artemis > Issue Type: Bug > Components: ActiveMQ-Artemis-Native >Affects Versions: 2.25.0 >Reporter: Andrey Slepykh >Assignee: Clebert Suconic >Priority: Major > Attachments: image-2024-06-19-18-06-30-222.png > > > !image-2024-06-19-18-06-30-222.png! > you are using the Integer.valueOf [in line > 89|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L89] > method which hashes the information, although ultimately the > connectionCountThreshold variable is only used for comparison using the "if" > on line > [53|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L53] > of the same file > Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. > Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (ARTEMIS-4825) EQ_UNUSUAL idempotent function
Andrey Slepykh created ARTEMIS-4825: --- Summary: EQ_UNUSUAL idempotent function Key: ARTEMIS-4825 URL: https://issues.apache.org/jira/browse/ARTEMIS-4825 Project: ActiveMQ Artemis Issue Type: Bug Components: ActiveMQ-Artemis-Native Affects Versions: 2.25.0 Reporter: Andrey Slepykh Assignee: Clebert Suconic Attachments: image-2024-06-19-18-15-06-497.png !image-2024-06-19-18-15-06-497.png! after overriding the [equals()|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/utils/SecurityManagerUtil.java#L61] method it always returns true Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (ARTEMIS-4824) code overload DM_BOXED_PRIMITIVE_FOR_PARSING
Andrey Slepykh created ARTEMIS-4824: --- Summary: code overload DM_BOXED_PRIMITIVE_FOR_PARSING Key: ARTEMIS-4824 URL: https://issues.apache.org/jira/browse/ARTEMIS-4824 Project: ActiveMQ Artemis Issue Type: Bug Components: ActiveMQ-Artemis-Native Affects Versions: 2.25.0 Reporter: Andrey Slepykh Assignee: Clebert Suconic Attachments: image-2024-06-19-18-06-30-222.png !image-2024-06-19-18-06-30-222.png! you are using the ```Integer.valueOf``` [in line 89|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L89] method which hashes the information, although ultimately the connectionCountThreshold variable is only used for comparison using the "if" on line [53|https://github.com/apache/activemq-artemis/blob/fb1b362b473cad51ae5d05a897be02b1fa8461d4/artemis-server/src/main/java/org/apache/activemq/artemis/core/server/routing/policies/LeastConnectionsPolicy.java#L53] of the same file Found by Linux Verification Center (portal.linuxtesting.ru) with SVACE. Author: Firsov Vladimir, BMSTU (fvv22u...@student.bmstu.ru) -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Comment Edited] (AMQ-9514) How to set exclusive consumer for ws connector?
[
https://issues.apache.org/jira/browse/AMQ-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856290#comment-17856290
]
Ondrej Mrekaj edited comment on AMQ-9514 at 6/19/24 2:50 PM:
-
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp', 'ISYSUB']) as
websocket:
print("Connected to WebSocket")
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}")
if 'CONNECTED' not in response:
print("Failed to connect")
return
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue")
message = "Hello!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}")
while True:
incoming_message = await websocket.recv()
print(f"Received message: {incoming_message}")
asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
was (Author: JIRAUSER294523):
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp', 'ISYSUB']) as
websocket:
print("Connected to WebSocket")
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}")
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue")
message = "Hello!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
> How to set exclusive consumer for ws connector?
> ---
>
> Key: AMQ-9514
> URL: https://issues.apache.org/jira/browse/AMQ-9514
> Project: ActiveMQ Classic
> Issue Type: Bug
> Environment: ActiveMQ versions 5.15.3 and 5.18.3
>Reporter: Ondrej Mrekaj
>Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>
>
>
>
>
>
> {code}
> Additionally, I modified the connection string by adding
> {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}.
> What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
> connects using the WebSocket protocol.
> Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Comment Edited] (AMQ-9514) How to set exclusive consumer for ws connector?
[
https://issues.apache.org/jira/browse/AMQ-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856290#comment-17856290
]
Ondrej Mrekaj edited comment on AMQ-9514 at 6/19/24 2:50 PM:
-
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp']) as websocket:
print("Connected to WebSocket")
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}")
if 'CONNECTED' not in response:
print("Failed to connect")
return
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue")
message = "Hello!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}")
while True:
incoming_message = await websocket.recv()
print(f"Received message: {incoming_message}")
asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
was (Author: JIRAUSER294523):
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp', 'ISYSUB']) as
websocket:
print("Connected to WebSocket")
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}")
if 'CONNECTED' not in response:
print("Failed to connect")
return
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue")
message = "Hello!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}")
while True:
incoming_message = await websocket.recv()
print(f"Received message: {incoming_message}")
asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
> How to set exclusive consumer for ws connector?
> ---
>
> Key: AMQ-9514
> URL: https://issues.apache.org/jira/browse/AMQ-9514
> Project: ActiveMQ Classic
> Issue Type: Bug
> Environment: ActiveMQ versions 5.15.3 and 5.18.3
>Reporter: Ondrej Mrekaj
>Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>
>
>
>
>
>
> {code}
> Additionally, I modified the connection string by adding
> {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}.
> What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
> connects using the WebSocket protocol.
> Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Comment Edited] (AMQ-9514) How to set exclusive consumer for ws connector?
[
https://issues.apache.org/jira/browse/AMQ-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856290#comment-17856290
]
Ondrej Mrekaj edited comment on AMQ-9514 at 6/19/24 2:47 PM:
-
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp', 'ISYSUB']) as
websocket:
print("Connected to WebSocket")
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}")
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue")
message = "Hello!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
was (Author: JIRAUSER294523):
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp', 'ISYSUB']) as
websocket: print("Connected to WebSocket") # Send the CONNECT
frame with username and password to establish the connection
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}") # Check if
connection was successful
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue") # Send a message to the queue
message = "Hello, World!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
# Receive and print messages from the queue
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
> How to set exclusive consumer for ws connector?
> ---
>
> Key: AMQ-9514
> URL: https://issues.apache.org/jira/browse/AMQ-9514
> Project: ActiveMQ Classic
> Issue Type: Bug
> Environment: ActiveMQ versions 5.15.3 and 5.18.3
>Reporter: Ondrej Mrekaj
>Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>
>
>
>
>
>
> {code}
> Additionally, I modified the connection string by adding
> {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}.
> What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
> connects using the WebSocket protocol.
> Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Comment Edited] (AMQ-9514) How to set exclusive consumer for ws connector?
[
https://issues.apache.org/jira/browse/AMQ-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856290#comment-17856290
]
Ondrej Mrekaj edited comment on AMQ-9514 at 6/19/24 2:46 PM:
-
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password" async with websockets.connect(url,
subprotocols=['stomp', 'ISYSUB']) as websocket: print("Connected to
WebSocket") # Send the CONNECT frame with username and password to
establish the connection
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}") # Check if
connection was successful
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue") # Send a message to the queue
message = "Hello, World!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
# Receive and print messages from the queue
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
was (Author: JIRAUSER294523):
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:" # Replace with your WebSocket URL
username = "username"
password = "password" async with websockets.connect(url,
subprotocols=['stomp', 'ISYSUB']) as websocket: print("Connected to
WebSocket") # Send the CONNECT frame with username and password to
establish the connection
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}") # Check if
connection was successful
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue") # Send a message to the queue
message = "Hello, World!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
# Receive and print messages from the queue
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
> How to set exclusive consumer for ws connector?
> ---
>
> Key: AMQ-9514
> URL: https://issues.apache.org/jira/browse/AMQ-9514
> Project: ActiveMQ Classic
> Issue Type: Bug
> Environment: ActiveMQ versions 5.15.3 and 5.18.3
>Reporter: Ondrej Mrekaj
>Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>
>
>
>
>
>
> {code}
> Additionally, I modified the connection string by adding
> {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}.
> What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
> connects using the WebSocket protocol.
> Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail:
[jira] [Comment Edited] (AMQ-9514) How to set exclusive consumer for ws connector?
[
https://issues.apache.org/jira/browse/AMQ-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856290#comment-17856290
]
Ondrej Mrekaj edited comment on AMQ-9514 at 6/19/24 2:46 PM:
-
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password"
async with websockets.connect(url, subprotocols=['stomp', 'ISYSUB']) as
websocket: print("Connected to WebSocket") # Send the CONNECT
frame with username and password to establish the connection
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}") # Check if
connection was successful
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue") # Send a message to the queue
message = "Hello, World!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
# Receive and print messages from the queue
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
was (Author: JIRAUSER294523):
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:"
username = "username"
password = "password" async with websockets.connect(url,
subprotocols=['stomp', 'ISYSUB']) as websocket: print("Connected to
WebSocket") # Send the CONNECT frame with username and password to
establish the connection
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}") # Check if
connection was successful
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue") # Send a message to the queue
message = "Hello, World!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
# Receive and print messages from the queue
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
> How to set exclusive consumer for ws connector?
> ---
>
> Key: AMQ-9514
> URL: https://issues.apache.org/jira/browse/AMQ-9514
> Project: ActiveMQ Classic
> Issue Type: Bug
> Environment: ActiveMQ versions 5.15.3 and 5.18.3
>Reporter: Ondrej Mrekaj
>Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>
>
>
>
>
>
> {code}
> Additionally, I modified the connection string by adding
> {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}.
> What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
> connects using the WebSocket protocol.
> Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For
[jira] [Commented] (AMQ-9514) How to set exclusive consumer for ws connector?
[
https://issues.apache.org/jira/browse/AMQ-9514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856290#comment-17856290
]
Ondrej Mrekaj commented on AMQ-9514:
Here is an connection example:
{code:java}
import asyncio
import websockets
import base64async def subscribe_and_send():
url = "ws://:" # Replace with your WebSocket URL
username = "username"
password = "password" async with websockets.connect(url,
subprotocols=['stomp', 'ISYSUB']) as websocket: print("Connected to
WebSocket") # Send the CONNECT frame with username and password to
establish the connection
connect_frame = (
f"CONNECT\n"
f"accept-version:1.2\n"
f"host:localhost\n"
f"login:{username}\n"
f"passcode:{password}\n\n\x00"
)
await websocket.send(connect_frame)
response = await websocket.recv()
print(f"Received CONNECT response: {response}") # Check if
connection was successful
if 'CONNECTED' not in response:
print("Failed to connect")
return # Subscribe to the queue
subscribe_frame =
"SUBSCRIBE\nid:sub-0\ndestination:/queue/FOO?consumer.exclusive=true\n\n\x00"
await websocket.send(subscribe_frame)
print("Subscribed to queue") # Send a message to the queue
message = "Hello, World!"
send_frame =
f"SEND\ndestination:/queue/FOO\ncontent-length:{len(message)}\n\n{message}\x00"
await websocket.send(send_frame)
print(f"Sent message: {message}") while True:
# Receive and print messages from the queue
incoming_message = await websocket.recv()
print(f"Received message:
{incoming_message}")asyncio.get_event_loop().run_until_complete(subscribe_and_send())
{code}
The {{subscribe_frame}} includes {*}{{?consumer.exclusive=true}}{*}, but it is
not being applied.
> How to set exclusive consumer for ws connector?
> ---
>
> Key: AMQ-9514
> URL: https://issues.apache.org/jira/browse/AMQ-9514
> Project: ActiveMQ Classic
> Issue Type: Bug
> Environment: ActiveMQ versions 5.15.3 and 5.18.3
>Reporter: Ondrej Mrekaj
>Priority: Major
>
> Hello,
> I attempted to edit the {{broker.xml}} file as follows:
> {code:java}
>
>
>
>
>
>
> {code}
> Additionally, I modified the connection string by adding
> {{{}?consumer.exclusive=true{}}}, so it now looks like this:
>
> {code:java}
> wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
> However, the {{Exclusive}} attribute is still being set to {{{}false{}}}.
> What might be causing this issue?
> I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
> connects using the WebSocket protocol.
> Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (ARTEMIS-4823) Upgrade BouncyCastle to 1.78.1
Domenico Francesco Bruscino created ARTEMIS-4823: Summary: Upgrade BouncyCastle to 1.78.1 Key: ARTEMIS-4823 URL: https://issues.apache.org/jira/browse/ARTEMIS-4823 Project: ActiveMQ Artemis Issue Type: Dependency upgrade Reporter: Domenico Francesco Bruscino Assignee: Domenico Francesco Bruscino -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (AMQ-9516) REST API adds unexpected byte when POSTing some messages
Ephemeris Lappis created AMQ-9516: - Summary: REST API adds unexpected byte when POSTing some messages Key: AMQ-9516 URL: https://issues.apache.org/jira/browse/AMQ-9516 Project: ActiveMQ Classic Issue Type: Bug Affects Versions: 5.18.3 Reporter: Ephemeris Lappis When sending messages using the REST API, some payloads are stored with an unexpected byte (0x0A) at the end of the text. This can be verified in the msg column field when using a JDBC persistence adapter. Sending the same messages using a usual JMS (open-wire) connection has never the problem. This issue is probably on the REST API's data handling... Anyway, most of messages are correctly processed, and this random behavior is perhaps depending on the size of the messages : for some of them the text is around 170.000 bytes. Short messages seem not to be altered. -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (AMQ-9515) Audit log contains message body when sent via the web console
Jean-Baptiste Onofré created AMQ-9515: - Summary: Audit log contains message body when sent via the web console Key: AMQ-9515 URL: https://issues.apache.org/jira/browse/AMQ-9515 Project: ActiveMQ Classic Issue Type: Bug Components: Web Console Reporter: Jean-Baptiste Onofré Assignee: Jean-Baptiste Onofré When sending a message via the WebConsole, the body of the message is fully displayed in the audit log. It's the only kind of messages behaving this way. We should not display message body in audit log, or at least we should have a configuration to control this. -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (AMQ-9514) How to set exclusive consumer for ws connector?
Ondrej Mrekaj created AMQ-9514:
--
Summary: How to set exclusive consumer for ws connector?
Key: AMQ-9514
URL: https://issues.apache.org/jira/browse/AMQ-9514
Project: ActiveMQ Classic
Issue Type: Bug
Environment: ActiveMQ versions 5.15.3 and 5.18.3
Reporter: Ondrej Mrekaj
Hello,
I attempted to edit the {{broker.xml}} file as follows:
{code:java}
{code}
Additionally, I modified the connection string by adding
{{{}?consumer.exclusive=true{}}}, so it now looks like this:
{code:java}
wss://HOST:IP/queue/FOO?consumer.exclusive=true {code}
However, the {{Exclusive}} attribute is still being set to {{{}false{}}}. What
might be causing this issue?
I tried this configuration in ActiveMQ versions 5.15.3 and 5.18.3. The client
connects using the WebSocket protocol.
Thank you.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Comment Edited] (ARTEMIS-4822) improve build reproducibility
[
https://issues.apache.org/jira/browse/ARTEMIS-4822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856248#comment-17856248
]
Robbie Gemmell edited comment on ARTEMIS-4822 at 6/19/24 11:45 AM:
---
{quote}commit ae8fd6dbdbae2653194512b97484a27440a38f6d
Author: Robbie Gemmell
Date: Wed Jun 19 10:01:13 2024 +0100
ARTEMIS-4822: disable timestamps in PDF metadata, making it and
artemis-website output reproducible
{quote}
[https://github.com/apache/activemq-artemis/commit/ae8fd6dbdbae2653194512b97484a27440a38f6d]
was (Author: gemmellr):
{quote}
commit ae8fd6dbdbae2653194512b97484a27440a38f6d
Author: Robbie Gemmell
Date: Wed Jun 19 10:01:13 2024 +0100
ARTEMIS-4822: disable timestamps in PDF metadata, making it and
artemis-website output reproducible
{quote}
https://github.com/apache/activemq-artemis/commit/ae8fd6dbdbae2653194512b97484a27440a38f6d
> improve build reproducibility
> -
>
> Key: ARTEMIS-4822
> URL: https://issues.apache.org/jira/browse/ARTEMIS-4822
> Project: ActiveMQ Artemis
> Issue Type: Task
>Reporter: Robbie Gemmell
>Assignee: Robbie Gemmell
>Priority: Major
> Fix For: 2.36.0
>
>
> The artemis-website modules output is not currently reproducible, even though
> all the HTML output in it is, because the PDF of the user manual now also
> added contains an embedded creation timestamp.
> The artemis-commons module pom is a dependency-reduced-pom created by the
> shade plugin. It can vary with maven version used during the build, and
> whether the release profile is active or not. We can improve the former by
> requiring the newer maven versions are used during release. We could
> investigate if the latter could be improved by adjusting the pom slightly to
> alter the varying bits (around the javadoc plugin) such that they dont.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Commented] (ARTEMIS-4822) improve build reproducibility
[
https://issues.apache.org/jira/browse/ARTEMIS-4822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17856248#comment-17856248
]
Robbie Gemmell commented on ARTEMIS-4822:
-
{quote}
commit ae8fd6dbdbae2653194512b97484a27440a38f6d
Author: Robbie Gemmell
Date: Wed Jun 19 10:01:13 2024 +0100
ARTEMIS-4822: disable timestamps in PDF metadata, making it and
artemis-website output reproducible
{quote}
https://github.com/apache/activemq-artemis/commit/ae8fd6dbdbae2653194512b97484a27440a38f6d
> improve build reproducibility
> -
>
> Key: ARTEMIS-4822
> URL: https://issues.apache.org/jira/browse/ARTEMIS-4822
> Project: ActiveMQ Artemis
> Issue Type: Task
>Reporter: Robbie Gemmell
>Assignee: Robbie Gemmell
>Priority: Major
> Fix For: 2.36.0
>
>
> The artemis-website modules output is not currently reproducible, even though
> all the HTML output in it is, because the PDF of the user manual now also
> added contains an embedded creation timestamp.
> The artemis-commons module pom is a dependency-reduced-pom created by the
> shade plugin. It can vary with maven version used during the build, and
> whether the release profile is active or not. We can improve the former by
> requiring the newer maven versions are used during release. We could
> investigate if the latter could be improved by adjusting the pom slightly to
> alter the varying bits (around the javadoc plugin) such that they dont.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
-
To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org
For additional commands, e-mail: issues-h...@activemq.apache.org
For further information, visit: https://activemq.apache.org/contact
[jira] [Created] (ARTEMIS-4822) improve build reproducibility
Robbie Gemmell created ARTEMIS-4822: --- Summary: improve build reproducibility Key: ARTEMIS-4822 URL: https://issues.apache.org/jira/browse/ARTEMIS-4822 Project: ActiveMQ Artemis Issue Type: Task Reporter: Robbie Gemmell Assignee: Robbie Gemmell Fix For: 2.36.0 The artemis-website modules output is not currently reproducible, even though all the HTML output in it is, because the PDF of the user manual now also added contains an embedded creation timestamp. The artemis-commons module pom is a dependency-reduced-pom created by the shade plugin. It can vary with maven version used during the build, and whether the release profile is active or not. We can improve the former by requiring the newer maven versions are used during release. We could investigate if the latter could be improved by adjusting the pom slightly to alter the varying bits (around the javadoc plugin) such that they dont. -- This message was sent by Atlassian Jira (v8.20.10#820010) - To unsubscribe, e-mail: issues-unsubscr...@activemq.apache.org For additional commands, e-mail: issues-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
