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

Added java.lang.Byte and java.lang.Short Valuefier support #9134

Open
wants to merge 1 commit into
base: main
Choose a base branch
from

Conversation

Twinkiee
Copy link

Faced this issue when dequeuing messages from an IBM MQ queue.
I added a couple more converters for java.lang.Byte and java.lang.Short which happened to be produced when the Logstash JMS plugin was deserializing the message headers.
Could not provide a meaningful (i.e. not trivial) unit test but I'd add one if asked/required.

@elasticmachine
Copy link
Collaborator

Since this is a community submitted pull request, a Jenkins build has not been kicked off automatically. Can an Elastic organization member please verify the contents of this patch and then kick off a build manually?

@Twinkiee Twinkiee closed this Feb 13, 2018
@Twinkiee Twinkiee reopened this Feb 13, 2018
@elasticmachine
Copy link
Collaborator

Since this is a community submitted pull request, a Jenkins build has not been kicked off automatically. Can an Elastic organization member please verify the contents of this patch and then kick off a build manually?

@guyboertje guyboertje self-assigned this Feb 16, 2018
@guyboertje
Copy link
Contributor

We have a serious conflict of interest here.

On the one hand we can't introduce valuefier convertors for every possible type that may enter Logstash from the various technologies used by plugins when they create a field/value combination. This implies that it is up to the plugin to do the normalisation, for example, from JDBC sql types.

On the other hand, given that these are standard Java types, Byte and Short should probably be added.

@original-brownbear WDYT?

@elasticmachine
Copy link
Collaborator

Since this is a community submitted pull request, a Jenkins build has not been kicked off automatically. Can an Elastic organization member please verify the contents of this patch and then kick off a build manually?

@guyboertje
Copy link
Contributor

Jenkins please test this

@original-brownbear
Copy link
Member

@guyboertje

On the other hand, given that these are standard Java types, Byte and Short should probably be added.

I agree, byte and short should simply be cast to int and handled accordingly.

@@ -112,6 +112,8 @@ private static Object fallbackConvert(final Object o, final Class<?> cls) {
converters.put(RubyBignum.class, IDENTITY);
converters.put(RubyBigDecimal.class, IDENTITY);
converters.put(String.class, input -> RubyUtil.RUBY.newString((String) input));
converters.put(Byte.class, input -> RubyUtil.RUBY.newString(input.toString()));
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Twinkiee why don't we cast to int here and use LONG_CONVERTER as well? Seems more logical to me since a byte is a numeric type and not necessarily equivalent to a char in a String.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I agree with @original-brownbear. At the local Event level a byte is a number.

However, I looked at the IBM MQ Java docs. I wanted to know if the byte is considered a ASCII character or a numeric value.

This header MQIIH can return a char for TranState.
I saw others that returned byte[].
Via the CodedCharSetId, messages can be in UTF8 or CCS-2 (and variants).

@Twinkiee
Given that, at the event level, we don't know what the byte represents, it seems like the jms plugin is a better place to code for this.

Copy link
Author

@Twinkiee Twinkiee Feb 20, 2018

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@original-brownbear @guyboertje
It seems reasonable to me as well to convert the Byte as int as a general rule. That's how the java.lang.Byte#toString() threats the internal value anyway so there's really no point to behave differently.
I could/should've coded it in the first place, my bad.

On the other hand I'll try to investigate if it's actually possible for the IBM MQ to return a byte which is actually a char.
As far as I know, that's not the case. Sorry if it caused any confusion.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Twinkiee

Any progress on your investigation of IBM MQ char as byte investigation?

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@guyboertje
Hey, sorry for the late reply.
No, by my tests and investigations I couldn't find a byte converted into a char.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

👍

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@Twinkiee
Please make the update that @original-brownbear suggests then we can move this forward.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

5 participants