The TODOs

The PR update the following:

add a funny joke

Hey @yisim—congrats on submitting a PR at the end of the git course! I hope that you enjoyed the course and that you learnt a lot in doing it.
If you weren't already using git for your code, hopefully this has inspired you to do so. I hope that you enjoy the "Mastering Git" video course as well—you'll soon be able to get git to bend to your will :)
You can now wear this #GitWarrior badge with pride—and Tweet your historic victory!

sam


fix/PRO-2387/update-prime-sdk

Description

How Has This Been Tested?

Screenshots (if appropriate):
Types of changes

[ ] Bug fix (non-breaking change which fixes an issue)
[ ] New feature (non-breaking change which adds functionality)
[ ] Breaking change (fix or feature that would cause existing functionality to change)

In progress...


⚠ SolarOscp has degraded performance

In 9b4f47a, SolarOscp ($SOLAROSCP_URL) experienced degraded performance:

HTTP code: 200
Response time: 422 ms

Resolved: SolarOscp performance has improved in ab994db after 12 minutes.


netcdf view should load the list of attachment

Get inspired by
http://www.cheminfo.org/Image/Biology/Counting_plates/index.html
And look in the init script

And add a drag and drop box

Done https://my.cheminfo.org/?v=HEAD&direct=true&viewURL=https%3A%2F%2Fmydb.cheminfo.org%2Fdb%2Fvisualizer%2Fentry%2F4c780891cf01161040b0d17b73af9704%2Fview.json


Remade PR#11

Coverage remained the same at 100.0% when pulling 058e578bab7ee0508bea53afb51be27855159eac on tonel-migration into 87af548dc16c913cae0318c9e06592c87a819619 on master.


Improve filtering ui

Here are some suggestions for improving the filtering ui:

[ ] Sliders as input for numeric inputs: frequency filtering, CADD scores and (not implemented) SV size for example
[ ] Reduce size of Gene box
[ ] Drop consequences / impact severity filters from SV mode [EDIT: useful for smaller SVs]
[ ] Change colors of Filter and Reset buttons
[ ] Text and nr indicator of active filter (i.e. 'Filtered, showing 32 of 45000 variants')

Not in the list, but on Friday @robinandeer and me (mainly Robin) implemented the following behaviour:

If there is not filter applied, the Filters dropdown is folded. Otherwise is unfolded.

This way the user quickly knows if a filter is being applied or not.

The filter box open when pushing load more

Hi @vasiliosz ,
Some comments:

I'm not sure sliders are the best choice always in case of numeric input. If the range is too big and/or requires a lot of precision (i.e lots of decimals) can be very uncomfortable to slide a bar. I can see in the frequency filter, for example, that there is 0.0004, this is the kind of precision I'm talking about. What are the possible ranges and precision for the other number input fields?
We talked about indicating something like "Showing X from Y loaded variants", problem is that puzzle doesn't load all variants at once and we may not know how many there are in total. What we could do is load up to a number fixed of variants Z, then show something like "Showing X of Z+ variants, apply another filter to reduce the number of variants"... maybe?

what do you think?

Sounds good @guillermo-carrasco. Agree that sliders may not be practical always, depending on the needed resolution. But it is also not completely intuitive at the moment that you're entering max frequency as fraction.
Does puzzle not count the rows at any point? During load or any other time? If so, I agree with your proposal. The idea is to set some sort of reference for the effect of variant filtration etc

Iff the vcf has been indexed, the number of records would presumably be in the index..
bcftools index -n hapmap_pos.vcf.gz
108

aha! @robinandeer , @moonso does the VCF plugin consider this information?

The problem is to know how many variants that pass a specific filter...


sim-se: syscall emulation of tgkill always returns EINVAL

Describe the bug
Due to a small logic bug, the syscall emulation of tgkill, implemented in tgkillFunc() in src/sim/syscall_emul.hh, always returns -EINVAL (invalid argument). Specifically, the logic bug is due to the following code using an "or" instead of an "and", resulting in an always-true condition:
if (sig != 0 || sig != OS::TGT_SIGABRT)
    return -EINVAL;

So when the application makes the following call to tgkill(2), it exits with "Invalid argument" instead of aborting the program:
if (syscall(SYS_tgkill, getpid(), gettid(), SIGABRT)) {
    perror("tgkill");
    exit(1);
}

Affects version
develop @ 84e0224
gem5 Modifications
None
To Reproduce
Steps to reproduce the behavior. Please assume starting from a clean repository:

Compile the attached C program, tgkill.c.zip: cc -static -o tgkill tgkill.c
Compile gem5 with command scons build/X86/gem5.opt
Execute the simulation with build/X86/gem5.opt configs/deprecated/example/se.py --cmd=./tgkill

If possible, please include the Python configuration script used and state clearly any parameters passed.
Terminal Output
gem5 Simulator System.  https://www.gem5.org
gem5 is copyrighted software; use the --copyright option for details.

gem5 version DEVELOP-FOR-23.1
gem5 compiled Sep  7 2023 11:48:37
gem5 started Sep  7 2023 12:03:58
gem5 executing on cafe3.stanford.edu, pid 138003
command line: ./build/X86/gem5.fast configs/deprecated/example/se.py --cmd=./tgkill

warn: The `get_runtime_isa` function is deprecated. Please migrate away from using this function.
warn: The se.py script is deprecated. It will be removed in future releases of  gem5.
warn: The `get_runtime_isa` function is deprecated. Please migrate away from using this function.
Global frequency set at<PHONE_NUMBER>000 ticks per second
warn: No dot file generated. Please install pydot to generate the dot file and pdf.
src/mem/dram_interface.cc:690: warn: DRAM device capacity (8192 Mbytes) does not match the address range assigned (512 Mbytes)
src/base/statistics.hh:279: warn: One of the stats is a legacy stat. Legacy stat is a stat that does not belong to any statistics::Group. Legacy stat is deprecated.
system.remote_gdb: Listening for connections on port 7000
**** REAL SIMULATION ****
src/sim/simulate.cc:194: info: Entering event queue @ 0.  Starting simulation...
src/sim/mem_state.cc:443: info: Increasing stack size by one page.
src/sim/syscall_emul.cc:74: warn: ignoring syscall mprotect(...)
tgkill: Invalid argument
Exiting @ tick 13663000 because exiting with last active thread context
Simulated exit code not 0! Exit code is 1

Expected behavior
The program should simply abort, like:
$ ./tgkill
Aborted

Host Operating System
Ubuntu 22.04
Host ISA
X86
Compiler used
GCC 11.0.4
Additional information
None

Fixed by #286.


Method 'Build' in type does not have an implementation

The issue
Trying to add an example to the OpenApiRequestBody following the guidelines in the documentation results in the following error message.
Method 'Build' in type 'xxx.AddMessageSample' from assembly 'xxx, Version=<IP_ADDRESS>, Culture=neutral, PublicKeyToken=null' does not have an implementation.

As you can see in the code below the Method build does have an implementation.... I'm clueless.
To Reproduce

Add the following decorator to the function.
[OpenApiRequestBody(contentType: MediaTypeNames.Application.Json, bodyType: typeof(AddMessageRequest), Required = true, Description = "xx.", Example = typeof(AddMessageSample))]

    public class AddMessageRequest
    {
        public string xx { get; set; }
        public string xxx{ get; set; }
    }

public class AddMessageSample : OpenApiExample<AddMessageRequest>
    {
        public override IOpenApiExample<AddMessageRequest> Build(NamingStrategy namingStrategy = null)
        {
            this.Examples.Add(
            OpenApiExampleResolver.Resolve(
                "Sample",
                new AddMessageRequest() { xx = "xx", xxx= "xxx" },
                namingStrategy
            ));
            return this;
        }
    }

Load the Swagger UI.

Removed some naming since I can't share this all.

After downgrading the Newtonsoft.Json package to version 12.0.3 everything started working again.
  <ItemGroup>
    <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
  </ItemGroup>

  <ItemGroup>
    <PackageReference Include="Newtonsoft.Json" Version="12.0.3" />
  </ItemGroup>


A value is not reactive when it is created by toRef with an plain object.

Vue version
v3.4.27 and the latest
Link to minimal reproduction
https://play.vuejs.org/#eNp9kk9P8zAMxr+KlUs3rVpf9HIa3cQfcYADIOCYS8m8LaxNqsTdJlX97jgJg0kgDpFi+/GTn5P04qptp7sOxUyUXjndEnikrl1Io5vWOoIeyD7jKod9RWqTg/Yxclgp0juEAVbONpCxSSaNNMoaT6BsZwjmqXfEHuhpBv9gyCEL+2x8AUUBmmBp0ZuMYG/dVpqi+K3/eNip0fiHU3DwCcDWOK3tehRhR9FsPA50cYiUyOGzAPMF9NIAH/rdKUWUSpEnFu4eeJVFuiW+Hw4Im7auCDkCKDdni77/JB+GsuA45t86ImvgUtVabedSRMVkIsViclYWqcrKsjixE7kgzzwrvZ6+e2v4fSJi6G5aXaN7bEkzrxSzBB9qVV3b/X3MkeswP+bVBtX2l/y7P4ScFE8OPbod8rjHGlVujZTKty8PeOD9V7Gxy65m9R/FZ+S77AJjkl13ZsnYJ7pIexd/mTbrV397IDT+OFQADcoh6qXg/3Xzx+jfuP+n57GPH0wMH+DI9Z0=
Steps to reproduce
Please run the above reproduction, and click the button.
What is expected?
count up when the button is clicked, and a watch callback should be triggered.
What is actually happening?
Nothing happens
System Info
No response
Any additional comments?
Is this behavior intended?

wrap the object with reactive will work: const count = toRef(reactive({ test: 0 }), 'test');

I think this is as expected, and the correct usage is the part you commented out in your code.

This might also be "confused" with the VueUse implementation which allows passing raw values in which are then converted into a ref.
I wonder if it'd make sense to replicate such behavior 🤔

This is expected behavior.
From the docs:

Can also be used to create a ref for a property on a source reactive object.

The source object must be reactive.


Enabling MSBuild 14 in the default native-compile target

Currently Helios won't build on machines that don't have VS2013 installed (only VS2015)

Hi @moozzyk, I'm your friendly neighborhood Microsoft Open Technologies, Inc. Pull Request Bot (You can call me MSOTBOT). Thanks for your contribution!

It looks like you're a Microsoft contributor (Pawel Kadluczka). If you're full-time, we DON'T require a Contribution License Agreement. If you are a vendor, please DO sign the electronic Contribution License Agreement. It will take 2 minutes and there's no faxing! https://cla2.msopentech.com.

TTYL, MSOTBOT;

:shipit:


Add CPU V2 Extended Topology support in PI spec (Bugzilla Bug 2551)

This issue was created automatically with bugzilla2github
Bugzilla Bug 2551
Date: 2020-02-23T20:42:47+00:00
From: @niruiyu
To:   @niruiyu
CC:   nobody, samer.el-haj-mahmoud, @vincent-j-zimmer
Last updated: 2020-05-24T22:04:19+00:00

Comment 11570
Date: 2020-03-05 20:14:41 +0000
From: nobody <>
is this related to code first process?

Comment 11697
Date: 2020-03-15 22:42:56 +0000
From: @niruiyu
(In reply to Liming Gao from comment #2)
> is this related to code first process?
I believe so:)
My understanding to code first process:

Is the ECR published in open source community? (YES, attached in this BZ)
Are the feedback to this ECR from PIWG sent to open source community? (No feedback yet.)

So it depends on whether the further feedback communication will be processed in open source community.

Comment 11742
Date: 2020-03-19 14:52:41 +0000
From: Samer El-Haj-Mahmoud <<samer.el-haj-mahmoud>>
Feedback from Arm: The concepts apply to Arm64 SoCs, and we see no issue with the proposal.

Comment 12685
Date: 2020-05-24 22:04:19 +0000
From: @niruiyu
PI 1.7a was published and the ECR content is already in the spec.

Comment 11408
Date: 2020-02-23 20:42:47 +0000
From: @niruiyu

Industry Specification: ---
Target OS: ---
Bugzilla Assignee(s): @niruiyu

Intel ® 64 and IA-32 Architectures Software Developer’s Manual introduces 6-level CPU topology information which can be reported through CPUID instruction: Package, Die, Tile, Module, Core and SMT. This is to support the new hardware topology in new CPUs. There are only 3 levels CPU topology before that. The ECR changes EFI_MP_SERVICES_PPI.GetProcessorInfo() and EFI_MP_SERVICE_PROTOCOL.GetProcessorInfo() to support returning the CPU 6-level topology information when caller requests.
AMD’s Architecture Programmer’s Manual also has the concept of “DIE”.
Per "E.4.16 Function 8000_001Eh—Processor Topology Information“ in AMD64 Architecture Programmer’s Manual Volume 3: General Purpose and System Instructions (http://support.amd.com/TechDocs/24594.pdf), CPUID returns NodesPerProcessor information in ECX of CPUID[0x8000_001E]. “Node in this context corresponds to a processor die”.

Comment 11863
Date: 2020-03-26 16:50:54 +0000
From: @vincent-j-zimmer
approved as errata for upcoming pi1.7a specification (ETA 2-3 weeks).

Comment 11409
Date: 2020-02-23 20:43:59 +0000
From: @niruiyu
Created attachment 464
PI spec change
Attachment: BZ-464-UEFI_PIWG_CPU_V2_EXTENDED_TOPOLOGY-ECR.doc


The script is not working with me

I have a images directory in the obsidian vault  and configured the config.js with right paths
but get the following error
[Error :ENONT: no such file or directory, open '/home/kareem/obsidian_valuts/logseq/religion/cool.md']{
errno:-2,
code: "ENOENT",
syscall: "open",
Path: "my_path",}

hi,
your path looks like it has obsidian_valuts in it, is it meant to be obsidian_vaults?

@rachsmithcodes yes!


sccache: init at 0.2.8

Motivation for this change
This is the beginning of a new compiler cache support for NixOS, starting with the bare package. As discussed here: https://discourse.nixos.org/t/use-sccache-for-rust-compilation-cache/3228 . Currently tests are disabled due to https://github.com/mozilla/sccache/issues/460 .
Things done

[X] Tested using sandboxing (nix.useSandbox on NixOS, or option sandbox in nix.conf on non-NixOS)
Built on platform(s)

[X] NixOS
[ ] macOS
[ ] other Linux distributions

[X] Tested via one or more NixOS test(s) if existing and applicable for the change (look inside nixos/tests) - not applicable.
[ ] Tested compilation of all pkgs that depend on this change using nix-shell -p nix-review --run "nix-review wip" - non depend.
[X] Tested execution of all binary files (usually in ./result/bin/)
[ ] Determined the impact on package closure size (by running nix path-info -S before and after)
[X] Assured whether relevant documentation is up to date
[X] Fits CONTRIBUTING.md.

This pull request has been mentioned on Nix community. There might be relevant details there:
https://discourse.nixos.org/t/use-sccache-for-rust-compilation-cache/3228/5

@GrahamcOfBorg build sscache

@GrahamcOfBorg build sccache


HystrixSampleSseServlet not sending data when ShallowEtagHeaderFilter is used

There's an issue when calling hystrix's /hystrix.stream endpoint and the Spring's ShallowEtagHeaderFilter  is used that basically caches the response content indefinitely and no response is sent to the client. Also the connection is kept alive and not terminated if the client cancels the request so that if more than the numberConnections request are made, a response with 503 (MaxConcurrentConnections reached) will be returned.
To reproduce, activate the filter as a bean in the spring context:
    @Bean
    public Filter shallowETagHeaderFilter() {
        return new ShallowEtagHeaderFilter();
    }

This is not the spring cloud Netflix repository


A1 can't stand and something wrong with rviz

I follow the order : 1.roslaunch unitree_description empty_world.launch  2. roslaunch legged_controllers load_controller.launch cheater:=true 3.rosrun rqt_controller_manager rqt_controller_manager 4.start the legged_controller option in rqt_controller_manager 5.enter the gait . The motors move in the gait i entered but the robot keep lie on the ground   When i use rviz, there is no robot or  scroll bar, and it give an error in the Global Status: unknown frame map. How can I fix this problem?

Set fixed frame of RViz to odom.

the error in rviz disappeared, but still no robot and scroll bar. I notice there is a warn in the roslaunch unitree_description empty_world.launch window,
[ WARN] [1664017856.345256560, 10.290000000]: The root link base has an inertia specified in the URDF, but KDL does not support a root link with an inertia.  As a workaround, you can add an extra dummy link to your URDF.
Is it normal?

the error in rviz disappeared, but still no robot and scroll bar. I notice there is a warn in the roslaunch unitree_description empty_world.launch window,
[ WARN] [1664017856.345256560, 10.290000000]: The root link base has an inertia specified in the URDF, but KDL does not support a root link with an inertia.  As a workaround, you can add an extra dummy link to your URDF.
Is it normal?

Yes, it's normal.

the error in rviz disappeared, but still no robot and scroll bar. I notice there is a warn in the roslaunch unitree_description empty_world.launch window,
[ WARN] [1664017856.345256560, 10.290000000]: The root link base has an inertia specified in the URDF, but KDL does not support a root link with an inertia.  As a workaround, you can add an extra dummy link to your URDF.
Is it normal?

The robot and scroll bar need to be added by yourself, you should learn how to use Rviz and rqt. This is some basics of ROS, I also suggest you should learn the brief introduction tutorial of ROS before play with this project.


th155: Spellcards error in th155 1.19beta and 1.21b

釣符「可愛い太公望」(Fishing Sign "Adorable Tai Gong Wang")

夢符「ご先祖様が見ているぞ」(Dream Sign "Ancestors are Watching you")

境界「溢れ出る漂流物」(Boundary "Overflowing Flotsam")

This issue should be caused by a lack of binhacks for versions 1.19beta and 1.21b; the release of spellcard wasn't ended after its declaration.

Back when v1.21 and v1.21b got released, I was quite busy, and everything seemed to work by just taking advantage of the v1.19beta4 support, so I didn't pay too much attention to it. Looking at it now, it seems that some things do need to updated for v1.21b (for example, the key in base_tasofro/th155/data/actor/koishi.nut.map is /Functions/108/Functions/0/Literals/1, but it should be /Functions/110/Functions/0/Literals/1).
I'll work on updating all the nut.map files.

fixed in thpatch/thcrap-tsa@0e9b66f1aba3aaabba5adc8f3e0dc47481bcebb7


how to write named lambda in LFE?

Hi, I'm still learning the mighty LFE by following the little schemer.
I'm writing rember_f in LFE
(defun rember-f (test?)
    (letrec-function ((rember-rec (match-lambda
        ((_ '()) '())
        ((a (cons h t)) (if (funcall test? a h)
            (rember-rec a t)
            (cons h (rember-rec a t)))))))
        (lambda (a t) (rember-rec a t)))) ; Can I return rember-rec without construct a "wrapper lambda"?

The last line I'm not sure about, In order to return the recursive lambda, I have to construct another "wrapper" lambda which works but seems not quite right for me, Is there a better way to write this?

This is not an answer to your question, but why not do the following instead:
(defun rember-f (test?) ()
  (match-lambda
    ([_ ()] ())
    ([a (cons h t)]
     (if (funcall test? h a)
       t
       (cons h (funcall (rember-f test?) a t))))))

N.B. I'm looking at my fourth edition book as I write this.

Here's a really contrived example that should answer your question:
(defmodule example
  (export (max 1)))

(defun max (x)
  (fletrec ((-max (y) (erlang:max x y)))
    (function -max 1)))

@rvirding, we're supposed to use function instead of fun these days, right?

@yurrriq help me again thank you. What's your fourth edition book? I'm willing to buy one if it's about LFE

I'm glad I could help! I meant my fourth edition copy of The Little Schemer.

@yurrriq I just tried your version that using function reference instead of construct "wrapper" lambda, I   compile both version into core erlang, they turn out to be the same:
'rember-f'/1 =
    %% Line 371
    fun (_test?) ->
    letrec
        'rember-rec'/2 =
        fun (_ 1 ,_ 0 ) ->
            case <_ 1 ,_ 0 > of
              <_ 2 ,[]> when 'true' ->
              []
              <_a,[_h|_t]> when 'true' ->
              case apply _test?
                   (_a, _h) of
                <'true'> when 'true' ->
                apply 'rember-rec'/2
                    (_a, _t)
                <'false'> when 'true' ->
                let <_ 3 > =
                    apply 'rember-rec'/2
                    (_a, _t)
                in  [_h|_ 3 ]
                ( <_omega> when 'true' ->
                  primop 'match_fail'
                      ('if_clause')
                  -| ['compiler_generated'] )
              end
( <_ 5 ,_ 4 > when 'true' ->
                ( primop 'match_fail'
                  ({'function_clause',_ 5 ,_ 4 })
                  -| [{'function_name',{'rember-f',1}}] )
            -| ['compiler_generated'] )
            end
    in  fun (_a,_t) ->
        apply 'rember-rec'/2
            (_a, _t)

So I guess the core form of function reference is internally construct the "wrapper" lambda, so besides the aesthetic reason, what are the other reason to choose function  over fun?

Interesting. That makes sense, though. What about the first approach I posted? That seems to more closely mirror the Scheme solution from the book, for better or for worse.

@yurrriq The first solution seems to construct a match-lambda for each recursion. I don't know is this have the same cost of using letrec-function


Feat/analytics for specfic pages

i needed it for my project so i made a fork to you, feel free to accept
this is based on #1

wrong branch sorry


Add pool of database connections for maintenance jobs

@jgpruitt maybe we can close this as #1657 was merged?


Remove: Unwanted Logs

Purpose
$subject
Related PRs

https://github.com/wso2/apk/pull/1266

Codecov Report
Patch coverage has no change and project coverage change: +49.55 :tada:

Comparison is base (3d9d942) 30.55% compared to head (8a82966) 80.10%.

Additional details and impacted files
@@             Coverage Diff             @@
##             main    #1307       +/-   ##
===========================================
+ Coverage   30.55%   80.10%   +49.55%
===========================================
  Files         338        9      -329
  Lines       39102      548    -38554
  Branches    11614      246    -11368
===========================================
- Hits        11948      439    -11509
+ Misses      26896      109    -26787
+ Partials      258        0      -258

Flag
Coverage Δ

adapter
?

admin-domain-service
?

backoffice-domain-service
?

config-deployer-service
?

devportal-domain-service
?

idp-domain-service
80.10% <ø> (ø)

runtime-domain-service
?

Flags with carried forward coverage won't be shown. Click here to find out more.
see 329 files with indirect coverage changes

:umbrella: View full report in Codecov by Sentry.
:loudspeaker: Do you have feedback about the report comment?


[Feature Request] Provide alternative path for configuration file in .config/

For modern CLI (and not CLI) app, storing the configuration directly under the home directory is no longer a trend. Storing it under .config/ will be much tidier. And considering AeroSpace won't introduce big breaking change for configuration, I believe it will be beneficial if we can have a second configuration location, i.e. ~/.config/aerospace.toml (simplest) or ~/.config/aerospace/config.toml (if you want to add other configuration files in the future, e.g. subconfigs, external assets). If .aerospace.toml doesn't exist, then AeroSpace will read files under .config/.

I expected that somebody would submit this issue one day or another
The reasons why I didn't implement it "properly" from the beginning:

It's unclear whether I should respect XDG_CONFIG_HOME environment variable (some apps respect it and others don't)

The decision on supporting it should be based on how easy it is to add environment variables for GUI apps in macOS (I never tried doing so, so I don't know it yet)

Normally, macOS uses $HOME/Library/Preferences or $HOME/Library/Application Support. I have not decided yet on whether I want to support them as alternative paths

* It's unclear whether I should respect `XDG_CONFIG_HOME` environment variable (some apps respect it and others don't)

Considering it could be a good option, but I don't see a lot of users setting this up. Instead, I see many applications either hardcoding .config, or supporting both version of configs.

* Normally, macOS uses `$HOME/Library/Preferences` or `$HOME/Library/Application Support`. I have not decided yet on whether I want to support them as alternative paths

Since AeroSpace uses the minimum amount of GUI, I would rather think it's a CLI app, which will usually not follow macOS's tradition but have more similarity with Linux's.
If we support multiple alternatives for config path, I don't think these concerns would become a issue since we can support them all. And I don't think the order will matter since typically users will only put their configuration at one place and they have to do it manually.

Agree with @XOR-op. To me, AeroSpace feels more like a CLI program - it has no interactive UI and relies on users to edit configurations manually.
I believe respecting XDG_CONFIG_HOME and checking ~/.aerospace.toml, $XDG_CONFIG_HOME/.config/aerospace.toml in turn would be a reasonable choice.
Thank you so much for creating AeroSpace; I love it, especially since it doesn't need to disable SIP <3

Another vote for allowing alternative locations. My preference would be ~/.config/aerospace/config.toml as mentioned above

Released in 0.8.0-Beta


GH-1210: Add Kotlin suspend functions support

Fixes https://github.com/spring-projects/spring-amqp/issues/1210
Kotlin Coroutines are essentially Future wrapping. Therefore, it is natural to have suspend support on @RabbitListener methods as we do now for CompletableFuture and Mono

Introduce some utilities since we cannot reuse existing from Spring Messaging: they are there about Kotlin Coroutines only for reactive handlers
Some code clean up in the RabbitListenerAnnotationBeanPostProcessor for the latest Java
Add optional dep for kotlinx-coroutines-reactor and document the feature

Hi there, quick question, will this feature be supported in version 2.7.14? Thanks!

@jhoanmanuelms We can take a look, but can provide no guarantee - it depends on how cleanly the code back ports; there are many changes in 3.0.x that might cause too many conflicts.
Please open a new issue so it's not forgotten.

@jhoanmanuelms Turns out the back port was not too challenging; however, I had to pull in an older version of kotlin coroutines because 2.4.x is used with Boot 2.7.x and the versions need to be aligned.
https://github.com/spring-projects/spring-amqp/pull/2519


utils uid broken because crypto not defined/imported

It's not imported into utils.

crypto is a global

What environment/context are you trying to use this code in?

Solved offline—I was using Node.js w/ this lib, oops.
If you want to use the crypto part of this and are running in Node.js 16+, can do the following:
// https://discord.com/channels/@me/562847915828314113/857647064074944532
globalThis.crypto = require('crypto').webcrypto

Edit: Removed private Discord link :)

Hilarious. I had not intended to include that.

Figured not lol 😅


Implement bincode Writer and Reader traits for Vec

I am working on a no_std embedded comms stack which talks to devices running C applications. The stack uses heapless::Vecs to handle the byte streams being sent and received, and I would like to use bincode to perform the conversion to / from Rust structures.
Right now, in order to do this I have to create a wrapper type around the heapless::Vec in order to implement bincode's Writer and Reader traits. It seems like this is a common enough pairing that it would make sense to have these traits implemented for heapless::Vec by default, or at least available through a feature, rather than having to re-implement for each new project working in this space.
I'm not sure whether it would make more sense for this implementation to live in the bincode crate or the heapless crate, so I've created an equivalent issue on the bincode repo. What do you think?

Yeah agreed, to me it would seem like it would make more sense for the implementation to live in the serialiser's crate rather than the collection's crate. Good to know there's precedent.


Fix chpwd clobbering in dirhistory and last-working-dir

dirhistory and last-working-dir clobber each other's chpwd functions when used together. This PR changes them both to append to chpwd_functions instead of clobbering chpwd

Thanks! One minor change to the code style: use chpwd_functions+=(function) instead of the other one (that's the preferred way to add an element to an array). Also, you don't need the typeset -ga stuff since those variables are already global and accessible when the plugins are sourced.

@mcornella Thanks for the tips! I've made the style fixes as requested.

Cool! This is ready to merge
/cc @robbyrussell


No copies printed

Reopened with new number, because it still isn't markes as bug.
My Kyocera P5021cdw (wireless connection, colour laser, double-sided) prints multiple copies, everything is fine.
My Brother DCP-L2530DW (wireless connection, b/w laser, double-sided) doesn't print copies anymore,
when I need 10 copies I have to select printing e.g. from PDF viewer or LibreOffice print menu 10 times.
It doesn't matter how many pages the document contains or I f double-sided is chosen or what else.
"10 copies" is simply ignored - seems to be accepted - but only one is printed.
I have no idea how long this problem already exists (at least some months, but had no time to report it)
and wonder how this can be fixed.
address: dnssd://Brother%20DCP-L2530DW%20series._ipp._tcp.local/?uuid=e32...xxxxxxxxxxxxxxxx....88 (uuid manually replaced)
Make/model: Brother DCP-L2530DW series, driverless, cups-filters 1.27.4
Linux Mint 20.3 Una 64bit
Linux 5.13.0-27-generic
Cinnamon 5.2.7
If more information is needed I will provide it asap.

@DirkHaar  could you please provide the whole ppd file just make save it as a txt file and attach it here it could help in better understanding of problem

@DirkHaar  could you please try following solution
update it to new version of cupsfliter 1.28.0 as there were some fixes for same type of issue #242 and #255
And in issue #242 there were problem with a attribute in PPD which was false and chaging it to true solved that problem but it is missing in you ppd which was *cupsManualCopies: True  but i cannot find the attribute at all in your PPD . could you please try to add this attribute in you ppd and and restart the cups once again and see if problem resolved and still exist.
and one more thing
Run the command
cupsctl --debug-logging
before Trying to print the multiple-copy job again. Then attach your /var/log/cups/error_log file here (remember that you have to rename the file to have a .txt extension so that you can attach it here). so that can see where the problem is

Hi Chandresh, thanks for jumping in.

My system has no open updates, so how do I update the cups-filter file manually?
Further information I forgot: Linux Mint 20.3 Una, Linux 5.13.0-27-generic, Cinnamon 5.2.7
The PPD above is complete, besides
*cupsManualCopies: True

The setting was
*cupsManualCopies: true
When wondering about no copies I found thatt and I did not understand why this should not be "false".
False does not work either.
I compared it to my Kyocera ppd  which has no such entry at all, so I removed the line
(giving the content above you consider incompete) which doesn't work too.
Attached the log (without updating) for a test with three copies and
*cupsManualCopies: false
cupslog.txt

@DirkHaar  thanks for Providing logs , but could you do one thing this may work or not.
Actually the issue I mentioned #242  has same type of issue with they tried both true/false but the actual problem was that these were case sensitive so true and false mean nothing there instead they have to use True / False after changing these attributes there problem fixed permanently.
Could you please try this once in the meantime i will go through youlogs and will try to find out if something else is creating the issue.

@DirkHaar  don't forget to restart cups after changing ppd. or just stop it before changing with
sudo systemctl stop cups
and after changing start with
sudo systemctl start cups
and then print

@DirkHaar  did you tried it

TLDR;
Solution:
either update cups-filters to v1.28 OR use
*cupsManualCopies: True
in the ppd file.


forward_context seems useless because cross-multi-head attention is not used.

it seems context information are not used in decoder->forward in https://github.com/NVIDIA/FasterTransformer/blob/dd4c071755b1b5206c6987add6145eac03f6814d/fastertransformer/gpt.h#L595
because is_cross_attention is false. and I delete this forward_context and remake it, then run demo again find result not changed. https://github.com/NVIDIA/FasterTransformer/blob/dd4c071755b1b5206c6987add6145eac03f6814d/fastertransformer/gpt.h#L395
so what need I do if I want to use context-information, set global variable in forward_context?

I don't know what demo you run. If the demo does not contains the context, then removing the forward_context is fine.
forward_context is used to compute the k/v cache of context, which are used in self attention, but not cross attention.

I don't know what demo you run. If the demo does not contains the context, then removing the forward_context is fine.
forward_context is used to compute the k/v cache of context, which are used in self attention, but not cross attention.

thank you for help, I run gpt_sample demo with head_num=96,layers=1,batch=1, maybe in this demo k/v cache influence not enought.

Can you provide all hyper-parameters you use?
batch_size=1
input_len=?
output_len=?
Environment=?(TF/PyTorch/C/Triton)
scripts=?

Can you provide all hyper-parameters you use?
batch_size=1
input_len=?
output_len=?
Environment=?(TF/PyTorch/C/Triton)
scripts=?

input_len=512
output_len=32
environment=c
scripts=./bin/gpt_sample

This example uses the cache. If you remove the forward_context, the results should be wrong.

Can you provide all hyper-parameters you use?
batch_size=1
input_len=?
output_len=?
Environment=?(TF/PyTorch/C/Triton)
scripts=?

yes it uses the cache, but whether I used decoder->forward_context, out is "464 968 8221 2732 286 15198 318<PHONE_NUMBER> 12056 423<PHONE_NUMBER><PHONE_NUMBER> 3782 468 3199 663 5079"

This example uses the cache. If you remove the forward_context, the results should be wrong.

my gpu is 2080ti, when use forward_context it is 6.6ms, not use forward_context is 1.6ms

This example uses the cache. If you remove the forward_context, the results should be wrong.

my gpu is 2080ti, when use forward_context it is 6.6ms, not use forward_context is 1.6ms

The time makes sense, and it seems that there is no any problem.

Close this bug because it is inactivated. Feel free to re-open this issue if you still have any problem.


Added guidance on how to get appid and app key for appinsights

@KennieNP : Thanks for your contribution! The author(s) have been notified to review your proposed change.

@KennieNP
Thanks for making this change. :)
approved.

#sign-off


Build failure within --project but not regular build when using generic classes

Bug Report or Feature Request (mark with an x)
- [x] bug report -> please search issues before submitting
- [ ] feature request

I am trying to access  properties on a generic class with a library. The build fails when this code is within a project/library (--project) but the exact same setup within an Angular app, it compiles with no errors.
Command (mark with an x)
- [ ] new
- [x] build
- [ ] serve
- [ ] test
- [ ] e2e
- [ ] generate
- [ ] add
- [ ] update
- [ ] lint
- [ ] xi18n
- [ ] run
- [ ] config
- [ ] help
- [ ] version
- [ ] doc

Versions

Repro steps

So create a  library and a component within that library:
ng generate library questions
ng generate component question --project=questions

this is the content of the question.component.ts:
import { Component, OnInit, Input } from '@angular/core';
import { QuestionBase } from 'questions/lib/question-base';

@Component({
  selector: 'lib-question',
  templateUrl: './question.component.html',
  styleUrls: ['./question.component.css']
})
export class QuestionComponent implements OnInit {

  @Input() field: QuestionBase<any>;

  constructor() { }

  ngOnInit() {
  }

}

this is the content of question.component.html:
<p>
  test works!

  {{field.type}}
</p>

this is the content of question-base.ts (from https://angular.io/guide/dynamic-form#question-model)
export class QuestionBase<T> {
  value: T;
  key: string;
  label: string;
  required: boolean;
  order: number;
  controlType: string;

  constructor(options: {
      value?: T,
      key?: string,
      label?: string,
      required?: boolean,
      order?: number,
      controlType?: string
    } = {}) {
    this.value = options.value;
    this.key = options.key || '';
    this.label = options.label || '';
    this.required = !!options.required;
    this.order = options.order === undefined ? 1 : options.order;
    this.controlType = options.controlType || '';
  }
}

This does not compile correct with errors below. However, this exact same component and class code within an angular app rather than "project"/"library"... it compiles fine.
Any help appreciated, please let me know if you need more info.
The log given by the failure

BUILD ERROR
projects/questions/src/lib/question/question.component.ts.QuestionComponent.html(1,4): : Property 'type'does not exist on type 'QuestionBase<any>'.

Error: projects/questions/src/lib/question/question.component.ts.QuestionComponent.html(1,4): : Property'type' does not exist on type 'QuestionBase<any>'.

Desired functionality

To compile with no errors, just like the regular build does.
Mention any other details that might be useful

Hello, we reviewed this issue and determined that it doesn't fall into the bug report or feature request category. This issue tracker is not suitable for support requests, please repost your issue on StackOverflow using tag angular-cli.
If you are wondering why we don't resolve support issues via the issue tracker, please check out this explanation.
That said, the error is correct as there is no type public member in QuestionBase.  That said, I am not sure why you are trying to pass an instance of a class as an Input field.

I had a look at this, when using ng build - aot at application level the error is shown correctly. This is due that template checks are only done when using AOT and library compilation always use AOT.
Closing as it's working as intended.

Thanks for looking into this. This code is actually within the Angular docs, not sure where to raise where that should be corrected.
https://angular.io/guide/dynamic-form#question-model
Used in the same way. An instance of a class which extends the QuestionBase which does have a type property is passed into the @Input.

In yourcase the class that you are proving in the input doesn’t have type as a member and hence the error.
The ones in the Angular docs have a slight different implementation, which are extending the base class and declaring the type in the extended class.

Sorry, I've condensed the project to highlight the issue,
I've basically had the same setup as the dynamic forms in Angular docs, but the build fails on that type issue.

I manually made each element, but it's identical pretty much.

Any updates on this? The dynamic form tutorial in the Angular Docs doesn't compile when adding --aot. It says 'type' doesn't exist on type 'QuestionBase'


SCP module: calls unix scp and also sort

Used to copy the CDR files from the IMI machine and sort it.
Also used to copy the OBD file to the IMI machine.

Should I make this more of a platform module and call is something like the os module and then make the scp & sort more generic?
Or just move these methods to the imi module?

if imi is the only consumer I would just move them there.
On Thu, May 21, 2015 at 12:33 PM, Frank Huster<EMAIL_ADDRESS>wrote:

Should I make this more of a platform module and call is something like
the os module and then make the scp & sort more generic?
Or just move these methods to the imi module?
—
Reply to this email directly or view it on GitHub
https://github.com/motech-implementations/mim/pull/271#issuecomment-104396281
.

OK, I'll kill the scp module and move things to the IMI module.
It'll be one happy large CR-feedback checkin.

Moved scp & sort to the IMI module


[ACM-10806] [2.10] Update hub collector with the whole obs addon spec

This cherry picks the changes from #1386 and #1390 into the 2.10 release stream.

/retest


Remove multiple instances of including Placename in the report, i.e. just list that at the start.

Throughout the report, we have the same place name or lat / lon listed in each report section. We really only need a single instance of the place name at the top to indicate what the report represents.

Closed in #273


telephone mask

Dears, we installed in two phones, in one, we used 054...., but when I sent to this one some fuse tokens, I added him in my contact with +972-54.... , and he received a new SMS to install, but was already installed. After this, he could send to me (as for him, my number was a contact registered with +972..., and also from my side, when installing, I also used +972..., but when I tried to send him any quantity, he received on his phone with 054 only.  Maybe a simple mask with + (country) would solve for this moment.

@henry-hz Hey, Yes we may have some problems with phone numbers formatting.
Can you tell which app version you both were using? Also which android or ios?


export-name: crashes with "Cannot read property 'elements' of undefined"

Bug Report
The linting rule export-name crashes if there's a file containing only one export * from './Foobar'.

tslint-microsoft-contrib version: 6.0.0
TSLint version: 5.11.0
TypeScript version: 3.1.6
Running TSLint via: (pick one) CLI npx tslint --project .

TypeScript code being linted
export * from './ValidationWrapper';

with tslint.json configuration:
{
  "extends": ["tslint-eaa-contrib"],
  "linterOptions": {
    "exclude": [
      "config/**"
    ]
  }
}

(It's basically our own ruleset which enables / disables some rules, including from the tslint-microsoft-contrib package)
Actual behavior
npx tslint --project .
The 'export-name' rule threw an error in 'c:/Source/react-ocean-forms/src/components/withValidation/ValidationWrapper/index.ts':
TypeError: Cannot read property 'elements' of undefined
    at getExportsFromStatement (c:\Source\react-ocean-forms\node_modules\tslint-microsoft-contrib\exportNameRule.js:97:27)
    at ExportNameWalker.visitSourceFile (c:\Source\react-ocean-forms\node_modules\tslint-microsoft-contrib\exportNameRule.js:112:35)
    at ExportNameWalker.SyntaxWalker.visitNode (c:\Source\react-ocean-forms\node_modules\tslint\lib\language\walker\syntaxWalker.js:482:22)
    at ExportNameWalker.SyntaxWalker.walk (c:\Source\react-ocean-forms\node_modules\tslint\lib\language\walker\syntaxWalker.js:24:14)
    at Rule.AbstractRule.applyWithWalker (c:\Source\react-ocean-forms\node_modules\tslint\lib\language\rule\abstractRule.js:31:16)
    at Rule.apply (c:\Source\react-ocean-forms\node_modules\tslint-microsoft-contrib\exportNameRule.js:27:21)
    at Linter.applyRule (c:\Source\react-ocean-forms\node_modules\tslint\lib\linter.js:197:29)
    at c:\Source\react-ocean-forms\node_modules\tslint\lib\linter.js:139:85
    at Object.flatMap (c:\Source\react-ocean-forms\node_modules\tslint\lib\utils.js:151:29)
    at Linter.getAllFailures (c:\Source\react-ocean-forms\node_modules\tslint\lib\linter.js:139:32)

Expected behavior
Rule should not crash and no linting issue should be found.
It seems that the rule crashes if there's an file with only one export * from './Foobar'. The crash goes away if I have more than one export * from './Foo' per file.

is this fixed? Which version is it fixed in? I did update everything to latest one.

@cyberhck not releases yet.  6.1 is tracked in #788


Stop using Document for Registries

Index#documents_by_format and IndexForSearch#documents_by_format use the Document class to wrap results. This is not necessary - the only task it performs is converting the elasticsearch response, which return all fields as arrays.
We add a MultivalueConverter class to perform this task.
This cleans up the tests and removes the use of the Document from the search-side.
Trello: https://trello.com/c/oCWEBqER

For posterity, this change was inadvertently responsible for a massive improvement in Rummager's performance:

Average response time per day for the last 30 days.


Add Search posts as seen in documentation

Hey @Amoifr!
Thank you for this! However, I think we should remove/abandon this repository in favor of ux.symfony.com - so, https://github.com/symfony/ux/tree/2.x/ux.symfony.com - we can show as many live component demos there as we want.
I'll put it on my todo list to add some details to this repo's README that it is abandoned in favor of that site. I'd welcome any nice new demos over there for sure!
Cheers!

Please not that this repo is notice as a reference on https://symfony.com/bundles/ux-live-component/current/index.html

Thanks for the heads up @Amoifr, I'll create a pr to update the docs


Add ability to sort projects list

Current coverage is 98.22% (diff: 100%)

Merging #480 into master will increase coverage by 0.01%

@@             master       #480   diff @@
==========================================
  Files            37         37
  Lines           891        900     +9
  Methods           0          0
  Messages          0          0
  Branches          0          0
==========================================
+ Hits            875        884     +9
  Misses           16         16
  Partials          0          0

Powered by Codecov. Last update 9699d51...4795a06

LGTM


MINOR: adding filter variable for dev/tasks

Long overdue change to find tasks easily.
Tasks can be filtered by adding the q request variable (e.g. /dev/tasks/?q=test OR vendor/bin/sake dev/tasks q=test)

I'm assuming this is mostly for use in the browser, since getting tasks with sake you can just pipe into grep for the same functionality.
Not from my point of view. This requires you to know how to use grep, etc... I would keep it simpler (or provide some information on how to use grep).

If you guys like it then I will make a new pull request with everything sorted. I am not sure about the form though as we dont want to make it too fancy. Just simple.

Maybe we can add a little form, but then I think this should be Javascript based, not PHP based.

My 2c — even though it's quite a small addition, I personally think it's not a scope we want to support within the framework in the long term, mainly because there are other quite standard ways how to achieve the same without this — as Guy mentioned, in the CLI folks can use grep or other filtering mechanisms, in the browser you can search within the content of the page using CTLR/CMD+F shortcut.

Yeah - then lets leave it. Dont you think? I guess what would be awesome if we had some sort of autocomplete. I usually use CTRL+F on the screen, but most of the time I run it from command line and then I just copy the output and do a CTRL+F.
Maybe it is better to have the tasks grouped or something like that as we work on lots of projects with 50 or so tasks - where it is a real pain to find the right one.

Yeah - then lets leave it.
Closing this PR


[QUERY] Correct configuration for azure service bus using spring-cloud-azure-stream-binder-servicebus

Query/Question
We have a simple spring app that uses spring-cloud-stream to publish/consume events. We want to use manage-identity  for authentication and auto-creation of service bus topics/subscriptions. To do the same, we added spring-cloud-azure-stream-binder-servicebus binder and implemented user-assigned managed identity on azure.
Based on sample here, I added following configuration:
spring.cloud.azure.credential.managed-identity-enabled=true
spring.cloud.azure.credential.client-id=${AZURE_CLIENT_ID}
spring.cloud.azure.servicebus.namespace=<namespace>
spring.cloud.azure.servicebus.entity-type=topic

However starting the app, we get the following exception and the app is kind of blocked with no more logs:
2022-05-24 02:18:55.442 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.RequestResponseChannel         : {"az.sdk.message":"Settling message.","connectionId":"MF_10393e_1653358733489","linkName":"cbs","messageId":"1"}
2022-05-24 02:18:55.445  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.ActiveClientTokenManager       : {"az.sdk.message":"Scheduling refresh token task.","scopes":"https://servicebus.azure.net/.default"}
2022-05-24 02:18:55.463 ERROR [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.ActiveClientTokenManager       : {"az.sdk.message":"Error occurred while refreshing token that is not retriable. Not scheduling refresh task. Use ActiveClientTokenManager.authorize() to schedule task again.","exception":"period >= 0 required but it was -1488019624000000000","scopes":"https://servicebus.azure.net/.default","audience":"amqp://sb-befound-asb-297.servicebus.windows.net/createPerson/subscriptions/example-events-service.createPerson"}
java.lang.IllegalArgumentException: period >= 0 required but it was -1488019624000000000
    at reactor.core.publisher.FluxInterval.<init>(FluxInterval.java:52)
    at reactor.core.publisher.Flux.interval(Flux.java:1318)
    at reactor.core.publisher.Flux.interval(Flux.java:1298)
    at reactor.core.publisher.Flux.interval(Flux.java:1258)
    at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:106)
    at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:491)
    at reactor.core.publisher.EmitterProcessor.subscribe(EmitterProcessor.java:209)
    at reactor.core.publisher.Flux.subscribe(Flux.java:8469)
    at reactor.core.publisher.Flux.subscribeWith(Flux.java:8642)
    at reactor.core.publisher.Flux.subscribe(Flux.java:8439)
    at reactor.core.publisher.Flux.subscribe(Flux.java:8363)
    at reactor.core.publisher.Flux.subscribe(Flux.java:8333)
    at com.azure.core.amqp.implementation.ActiveClientTokenManager.scheduleRefreshTokenTask(ActiveClientTokenManager.java:158)
    at com.azure.core.amqp.implementation.ActiveClientTokenManager.lambda$authorize$2(ActiveClientTokenManager.java:93)
    at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:113)
    at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1816)
    at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:249)
    at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1816)
    at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:249)
    at reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1816)
    at reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:249)
    at reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:74)
    at reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:119)
    at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.complete(MonoIgnoreThen.java:292)
    at reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onNext(MonoIgnoreThen.java:187)
    at reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:165)
    at com.azure.core.amqp.implementation.RequestResponseChannel.settleMessage(RequestResponseChannel.java:398)
    at com.azure.core.amqp.implementation.RequestResponseChannel.lambda$new$0(RequestResponseChannel.java:180)
    at reactor.core.publisher.LambdaSubscriber.onNext(LambdaSubscriber.java:160)
    at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:120)
    at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:200)
    at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:491)
    at reactor.core.publisher.EmitterProcessor.tryEmitNext(EmitterProcessor.java:299)
    at reactor.core.publisher.SinkManySerialized.tryEmitNext(SinkManySerialized.java:100)
    at reactor.core.publisher.InternalManySink.emitNext(InternalManySink.java:27)
    at com.azure.core.amqp.implementation.handler.ReceiveLinkHandler.onDelivery(ReceiveLinkHandler.java:164)
    at org.apache.qpid.proton.engine.BaseHandler.handle(BaseHandler.java:185)
    at org.apache.qpid.proton.engine.impl.EventImpl.dispatch(EventImpl.java:108)
    at org.apache.qpid.proton.reactor.impl.ReactorImpl.dispatch(ReactorImpl.java:324)
    at org.apache.qpid.proton.reactor.impl.ReactorImpl.process(ReactorImpl.java:291)
    at com.azure.core.amqp.implementation.ReactorExecutor.run(ReactorExecutor.java:91)
    at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:68)
    at reactor.core.scheduler.SchedulerTask.call(SchedulerTask.java:28)
    at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
    at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    at java.base/java.lang.Thread.run(Thread.java:829)
2022-05-24 02:18:55.466 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ReceiveLinkHandler     : {"az.sdk.message":"onDelivery.","connectionId":"MF_10393e_1653358733489","errorCondition":null,"errorDescription":null,"entityPath":"$cbs","linkName":"cbs","updatedLinkCredit":0,"remoteCredit":0,"delivery.isPartial":false,"delivery.isSettled":false}
2022-05-24 02:18:55.468  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorSession    : {"az.sdk.message":"Creating a new receiver link.","connectionId":"MF_10393e_1653358733489","sessionName":"createPerson/subscriptions/example-events-service.createPerson","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583"}
2022-05-24 02:18:55.471 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorReceiver   : {"az.sdk.message":"State UNINITIALIZED","connectionId":"MF_10393e_1653358733489","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 02:18:55.472 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorReceiver   : {"az.sdk.message":"Token refreshed.","connectionId":"MF_10393e_1653358733489","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","response":"ACCEPTED"}
2022-05-24 02:18:55.480 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.m.s.ServiceBusReceiverAsyncClient    : {"az.sdk.message":"Created consumer for Service Bus resource.","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","entityPath":"createPerson/subscriptions/example-events-service.createPerson","mode":"PEEK_LOCK","isSessionEnabled":true,"entityType":"SUBSCRIPTION"}
2022-05-24 02:18:55.480  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.m.s.i.ServiceBusReceiveLinkProcessor : {"az.sdk.message":"Setting next AMQP receive link.","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 02:18:55.489  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.m.s.i.ServiceBusReceiveLinkProcessor : {"az.sdk.message":"Adding credits.","prefetch":0,"requested":1,"linkCredits":0,"expectedTotalCredit":1,"queuedMessages":0,"creditsToAdd":1,"messageQueueSize":0}
2022-05-24 02:18:55.492 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] .a.m.s.i.ServiceBusReactorAmqpConnection : {"az.sdk.message":"Get or create consumer.","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 02:18:55.492  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorSession    : {"az.sdk.message":"Returning existing receive link.","connectionId":"MF_10393e_1653358733489","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 02:18:55.494 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ReceiveLinkHandler     : {"az.sdk.message":"onLinkLocalOpen","connectionId":"MF_10393e_1653358733489","entityPath":"createPerson/subscriptions/example-events-service.createPerson","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","localSource":"Source{address='createPerson/subscriptions/example-events-service.createPerson', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}"}
2022-05-24 02:18:55.500 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorReceiver   : {"az.sdk.message":"State ACTIVE","connectionId":"MF_10393e_1653358733489","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 02:18:55.501  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ReceiveLinkHandler     : {"az.sdk.message":"onLinkRemoteOpen","connectionId":"MF_10393e_1653358733489","entityPath":"createPerson/subscriptions/example-events-service.createPerson","linkName":"createPerson/subscriptions/example-events-service.createPerson_53212c_1653358733583","remoteSource":"Source{address='createPerson/subscriptions/example-events-service.createPerson', durable=NONE, expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null, distributionMode=null, filter=null, defaultOutcome=null, outcomes=null, capabilities=null}"}

Adding subscription id and resourcegroup
spring.cloud.azure.credential.managed-identity-enabled: true
spring.cloud.azure.credential.client-id: ${AZURE_CLIENT_ID}
spring.cloud.azure.servicebus.namespace: <namespace>
spring.cloud.azure.servicebus.entity-type: topic
spring.cloud.azure.profile.subscription-id: <subscription-id>
spring.cloud.azure.servicebus.resource.resource-group: <resource-group>

This manages to get the token, but it tries to refresh the token on each operation and the startup of application is very  slow. The topics and subscription do get created but again its tried to fetch token again. Also, for topic to be created we have to hit a request that actually tried to push something to service bus. Follwing are the logs:
2022-05-24 01:49:49.296 DEBUG [example-events-service,,[] 1 --- [           main[] c.azure.identity.EnvironmentCredential   : Azure Identity => Found the following environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID
2022-05-24 01:49:49.298 DEBUG [example-events-service,,[] 1 --- [           main[] c.azure.identity.EnvironmentCredential   : Azure Identity => ERROR in EnvironmentCredential: Failed to create a ClientSecretCredential or ClientCertificateCredential. Missing required environment variable either AZURE_CLIENT_SECRET or AZURE_CLIENT_CERTIFICATE_PATH
2022-05-24 01:49:49.299 DEBUG [example-events-service,,[] 1 --- [           main[] c.azure.identity.EnvironmentCredential   : Azure Identity => ERROR in EnvironmentCredential: Failed to determine an authentication scheme based on the available environment variables. Please specify AZURE_TENANT_ID and AZURE_CLIENT_SECRET to authenticate through a ClientSecretCredential; AZURE_TENANT_ID and AZURE_CLIENT_CERTIFICATE_PATH to authenticate through a ClientCertificateCredential; or AZURE_USERNAME and AZURE_PASSWORD to authenticate through a UserPasswordCredential.
2022-05-24 01:49:49.323  INFO [example-events-service,,[] 1 --- [           main[] c.a.c.i.jackson.JacksonVersion           : Package versions: jackson-annotations=2.13.2, jackson-core=2.13.2, jackson-databind=<IP_ADDRESS>, jackson-dataformat-xml=2.13.2, jackson-datatype-jsr310=2.13.2, azure-core=1.26.0, Troubleshooting version conflicts: https://aka.ms/azsdk/java/dependency/troubleshoot
2022-05-24 01:49:49.424 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Found the following environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID
2022-05-24 01:49:49.426 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.identity.SharedTokenCacheCredential  : Azure Identity => Found the following environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID
2022-05-24 01:49:49.500 DEBUG [example-events-service,,[] 1 --- [           main[] s.c.c.i.c.AzureHttpProxyOptionsConverter : Proxy hostname or port is not set.
2022-05-24 01:49:49.501 DEBUG [example-events-service,,[] 1 --- [           main[] .f.AbstractAzureHttpClientBuilderFactory : No HTTP proxy properties available.
2022-05-24 01:49:49.502 DEBUG [example-events-service,,[] 1 --- [           main[] AbstractAzureServiceClientBuilderFactory : No authentication credential configured for class ManagedIdentityCredentialBuilder.
2022-05-24 01:49:49.502  INFO [example-events-service,,[] 1 --- [           main[] AbstractAzureServiceClientBuilderFactory : Will configure the default credential of type DefaultAzureCredential for class com.azure.identity.ManagedIdentityCredentialBuilder.
2022-05-24 01:49:49.510 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.c.i.http.HttpClientProviders         : Using com.azure.core.http.netty.NettyAsyncHttpClientProvider as the default HttpClientProvider.
2022-05-24 01:49:49.653 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Found the following environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID
2022-05-24 01:49:52.780  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' ...
2022-05-24 01:49:54.249  INFO [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:49:54.250  INFO [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:49:54.250  INFO [example-events-service,,[] 1 --- [           main[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token.
2022-05-24 01:49:55.119  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' finished in 2 seconds
2022-05-24 01:50:24.476  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:50:24.478  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:50:24.478  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:49:52.780  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' ...
2022-05-24 01:49:54.249  INFO [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:49:54.250  INFO [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:49:54.250  INFO [example-events-service,,[] 1 --- [           main[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token.
2022-05-24 01:49:55.119  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' finished in 2 seconds
2022-05-24 01:50:24.476  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:50:24.478  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:50:24.478  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:50:54.603  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:50:54.603  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:50:54.603  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:50:55.405  INFO [example-events-service,,[] 1 --- [           main[] zureServiceBusMessagingAutoConfiguration : Service Bus connection string is set from com.azure.spring.cloud.resourcemanager.implementation.connectionstring.ServiceBusArmConnectionStringProvider now.
2022-05-24 01:50:58.383  WARN [example-events-service,,[] 1 --- [           main[] .s.s.UserDetailsServiceAutoConfiguration :
+[
+[ Using generated security password: 4164cff7-b4be-44c1-a3a9-884ecb4e45ff
+[
+[ This generated password is for development use only. Your security configuration must be updated before running your application in production.
+[
2022-05-24 01:50:59.285 DEBUG [example-events-service,,[] 1 --- [           main[] s.c.c.i.c.AzureAmqpRetryOptionsConverter : The max-retries is not set, skip the convert.
2022-05-24 01:50:59.286 DEBUG [example-events-service,,[] 1 --- [           main[] .f.AbstractAzureAmqpClientBuilderFactory : No AMQP retry properties available.
2022-05-24 01:50:59.287 DEBUG [example-events-service,,[] 1 --- [           main[] s.c.c.i.c.AzureAmqpProxyOptionsConverter : Proxy hostname or port is not set.
2022-05-24 01:50:59.287 DEBUG [example-events-service,,[] 1 --- [           main[] .f.AbstractAzureAmqpClientBuilderFactory : No AMQP proxy properties available.
2022-05-24 01:50:59.292 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Found the following environment variables: AZURE_CLIENT_ID, AZURE_TENANT_ID
2022-05-24 01:50:59.294  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' ...
2022-05-24 01:51:25.615  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:51:25.616  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:51:25.616  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:51:25.900  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' finished in 26 seconds
2022-05-24 01:51:55.749  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:51:55.750  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:51:55.750  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:52:25.958  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:52:25.959  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:52:25.959  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:52:27.067  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' ...
2022-05-24 01:52:56.139  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:52:56.139  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:52:56.139  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:52:57.280  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' finished in 30 seconds
2022-05-24 01:53:26.295  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:53:26.295  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:53:26.296  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:53:56.472  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:53:56.472  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:53:56.472  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:53:57.978  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.ServiceBusClientBuilder          : {"az.sdk.message":"Setting entity from connection string.","entityPath":null}
2022-05-24 01:53:57.978 DEBUG [example-events-service,,[] 1 --- [           main[] AbstractAzureServiceClientBuilderFactory : Connection string configured for class ServiceBusClientBuilder.
2022-05-24 01:53:59.211  WARN [example-events-service,,[] 1 --- [           main[] iguration$LoadBalancerCaffeineWarnLogger : Spring Cloud LoadBalancer is currently working with the default cache. You can switch to using Caffeine cache, by adding it and org.springframework.cache.caffeine.CaffeineCacheManager to the classpath.
2022-05-24 01:53:59.637  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusSubscription with name 'example-events-service.createPerson' ...
2022-05-24 01:53:59.638  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching Topic with name 'createPerson' ...
2022-05-24 01:53:59.638  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' ...
2022-05-24 01:54:26.587  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:54:26.587  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:54:26.588  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:54:26.730  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' finished in 27 seconds
2022-05-24 01:54:56.735  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:54:56.736  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:54:56.736  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:54:57.489  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching Topic with name 'createPerson' finished in 57 seconds
2022-05-24 01:55:26.873  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:55:26.874  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:55:26.874  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:55:28.704  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusSubscription with name 'example-events-service.createPerson' finished in 89 seconds
2022-05-24 01:55:28.705  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Creating ServiceBusSubscription with name 'example-events-service.createPerson' ...
2022-05-24 01:55:28.705  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching Topic with name 'createPerson' ...
2022-05-24 01:55:28.705  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' ...
2022-05-24 01:55:56.980  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:55:56.980  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:55:56.980  INFO [example-events-service,,[] 1 --- [     parallel-2[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:55:57.132  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching ServiceBusNamespace with name 'sb-befound-asb-297' finished in 28 seconds
2022-05-24 01:56:27.104  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:56:27.104  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:56:27.104  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:56:27.875  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Fetching Topic with name 'createPerson' finished in 59 seconds
2022-05-24 01:56:57.224  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => Managed Identity environment: AZURE AKS TOKEN EXCHANGE
2022-05-24 01:56:57.225  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.identity.ManagedIdentityCredential   : Azure Identity => getToken() result for scopes [https://management.core.windows.net//.default]: SUCCESS
2022-05-24 01:56:57.225  INFO [example-events-service,,[] 1 --- [     parallel-1[] c.a.c.implementation.AccessTokenCache    : Acquired a new access token at<PHONE_NUMBER> seconds after expiry. Retry may be attempted after 30 seconds.
2022-05-24 01:56:58.105  INFO [example-events-service,,[] 1 --- [           main[] c.a.s.c.r.i.crud.AbstractResourceCrud    : Creating ServiceBusSubscription with name 'example-events-service.createPerson' finished in 89 seconds
2022-05-24 01:56:58.142 DEBUG [example-events-service,,[] 1 --- [           main[] a.s.m.l.AbstractMessageListenerContainer : Starting container with name null
2022-05-24 01:56:58.159 DEBUG [example-events-service,,[] 1 --- [           main[] s.c.c.i.c.AzureAmqpRetryOptionsConverter : The max-retries is not set, skip the convert.
2022-05-24 01:56:58.159 DEBUG [example-events-service,,[] 1 --- [           main[] .f.AbstractAzureAmqpClientBuilderFactory : No AMQP retry properties available.
2022-05-24 01:56:58.159 DEBUG [example-events-service,,[] 1 --- [           main[] s.c.c.i.c.AzureAmqpProxyOptionsConverter : Proxy hostname or port is not set.
2022-05-24 01:56:58.159 DEBUG [example-events-service,,[] 1 --- [           main[] .f.AbstractAzureAmqpClientBuilderFactory : No AMQP proxy properties available.
2022-05-24 01:56:58.160 DEBUG [example-events-service,,[] 1 --- [           main[] AbstractAzureServiceClientBuilderFactory : No authentication credential configured for class ServiceBusProcessorClientBuilder.
2022-05-24 01:56:58.161  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.ServiceBusClientBuilder          : {"az.sdk.message":"Setting entity from connection string.","entityPath":null}
2022-05-24 01:56:58.161 DEBUG [example-events-service,,[] 1 --- [           main[] AbstractAzureServiceClientBuilderFactory : Connection string configured for class ServiceBusProcessorClientBuilder.
2022-05-24 01:56:58.210 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.c.a.i.ReactorConnection              : {"az.sdk.message":"State UNINITIALIZED","connectionId":"MF_883a51_1653357418178"}
2022-05-24 01:56:58.211  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.i.ServiceBusConnectionProcessor  : {"az.sdk.message":"Setting next AMQP channel.","entityPath":"N/A"}
2022-05-24 01:56:58.211  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.i.ServiceBusConnectionProcessor  : {"az.sdk.message":"Next AMQP channel received, updating 0 current subscribers","entityPath":"N/A"}
2022-05-24 01:56:58.213 DEBUG [example-events-service,,[] 1 --- [           main[] c.a.c.a.i.ReactorConnection              : {"az.sdk.message":"State UNINITIALIZED","connectionId":"MF_34f0cd_1653357418213"}
2022-05-24 01:56:58.213  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.ServiceBusClientBuilder          : # of open clients with shared connection: 1
2022-05-24 01:56:58.225  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.ServiceBusReceiverAsyncClient    : {"az.sdk.message":"Creating consumer.","linkName":"createPerson/subscriptions/example-events-service.createPerson_860b64_1653357418225","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 01:56:58.232  INFO [example-events-service,,[] 1 --- [           main[] c.a.m.s.i.ServiceBusReceiveLinkProcessor : Requesting a new AmqpReceiveLink from upstream.
2022-05-24 01:56:58.236  INFO [example-events-service,,[] 1 --- [           main[] c.a.c.a.i.ReactorConnection              : {"az.sdk.message":"Creating and starting connection.","connectionId":"MF_883a51_1653357418178","hostName":"sb-befound-asb-297.servicebus.windows.net","port":5671}
2022-05-24 01:56:58.261  INFO [example-events-service,,[] 1 --- [           main[] c.a.c.a.implementation.ReactorExecutor   : {"az.sdk.message":"Starting reactor.","connectionId":"MF_883a51_1653357418178"}
2022-05-24 01:56:58.268  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ConnectionHandler      : {"az.sdk.message":"onConnectionInit","connectionId":"MF_883a51_1653357418178","hostName":"sb-befound-asb-297.servicebus.windows.net","namespace":"sb-befound-asb-297.servicebus.windows.net"}
2022-05-24 01:56:58.269  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ReactorHandler         : {"az.sdk.message":"reactor.onReactorInit","connectionId":"MF_883a51_1653357418178"}
2022-05-24 01:56:58.269  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ConnectionHandler      : {"az.sdk.message":"onConnectionLocalOpen","connectionId":"MF_883a51_1653357418178","errorCondition":null,"errorDescription":null,"hostName":"sb-befound-asb-297.servicebus.windows.net"}
2022-05-24 01:56:58.303  INFO [example-events-service,,[] 1 --- [           main[] .s.i.s.i.ServiceBusInboundChannelAdapter : started com.azure.spring.integration.servicebus.inbound.ServiceBusInboundChannelAdapter@7c9a5397
2022-05-24 01:56:58.705  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ConnectionHandler      : {"az.sdk.message":"onConnectionBound","connectionId":"MF_883a51_1653357418178","hostName":"sb-befound-asb-297.servicebus.windows.net","peerDetails":"sb-befound-asb-297.servicebus.windows.net:5671"}
2022-05-24 01:56:59.018  INFO [example-events-service,,[] 1 --- [           main[] com.backbase.example.Application         : Started Application in 436.628 seconds (JVM running for 437.627)
2022-05-24 01:56:59.203  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.StrictTlsContextSpi    : SSLv2Hello was an enabled protocol. Filtering out.
2022-05-24 01:56:59.277  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.ConnectionHandler      : {"az.sdk.message":"onConnectionRemoteOpen","connectionId":"MF_883a51_1653357418178","hostName":"sb-befound-asb-297.servicebus.windows.net","remoteContainer":"0550df7b353e4267af45866809a52cf1_G9"}
2022-05-24 01:56:59.279 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.ReactorConnection              : {"az.sdk.message":"State ACTIVE","connectionId":"MF_883a51_1653357418178"}
2022-05-24 01:56:59.281  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.m.s.i.ServiceBusConnectionProcessor  : {"az.sdk.message":"Channel is now active.","entityPath":"N/A"}
2022-05-24 01:56:59.299 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorSession    : {"az.sdk.message":"Got endpoint state.","connectionId":"MF_883a51_1653357418178","sessionName":"createPerson/subscriptions/example-events-service.createPerson","state":"UNINITIALIZED"}
2022-05-24 01:56:59.303 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.SessionHandler         : {"az.sdk.message":"onSessionLocalOpen","connectionId":"MF_883a51_1653357418178","errorCondition":null,"errorDescription":null,"sessionName":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 01:56:59.311  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.handler.SessionHandler         : {"az.sdk.message":"onSessionRemoteOpen","connectionId":"MF_883a51_1653357418178","sessionName":"createPerson/subscriptions/example-events-service.createPerson","sessionIncCapacity":0,"sessionOutgoingWindow":2147483647}
2022-05-24 01:56:59.311 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorSession    : {"az.sdk.message":"Got endpoint state.","connectionId":"MF_883a51_1653357418178","sessionName":"createPerson/subscriptions/example-events-service.createPerson","state":"ACTIVE"}
2022-05-24 01:56:59.312 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] .a.m.s.i.ServiceBusReactorAmqpConnection : {"az.sdk.message":"Get or create consumer.","entityPath":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 01:56:59.314 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.AzureTokenManagerProvider      : {"az.sdk.message":"Creating new token manager.","audience":"amqp://sb-befound-asb-297.servicebus.windows.net/createPerson/subscriptions/example-events-service.createPerson","resource":"createPerson/subscriptions/example-events-service.createPerson"}
2022-05-24 01:56:59.365  INFO [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.i.ReactorConnection              : {"az.sdk.message":"Setting CBS channel.","connectionId":"MF_883a51_1653357418178"}
2022-05-24 01:56:59.370 DEBUG [example-events-service,,[] 1 --- [ctor-executor-1[] c.a.c.a.implementation.ReactorSession    : {"az.sdk.message":"Got endpoint state.","connectionId":"MF_883a51_1653357418178","sessionName":"cbs-session","state":"UNINITIALIZED"}
2022-05-24 01:56:59.372 DEBUG [example-eve

The token expiry is set to 1 day in the cluster.
#Library/Libraries:

Spring boot - :2.6.6
Spring Cloud - 2021.0.0
spring-cloud-azure-stream-binder-servicebus - 4.0.0

Can someone help with the correct configuration for spring apps with managed identity and suggestion on how to auto-create topics at application startup without having to run a test request?

@dhananjay12
Thank you for your reporting!  Let's conclude the point of your concern in the following:

Auto creation of topic and subscription after start.
Token expiration doesn't take effect.
I will give a reply for this later.

Thanks for looking into this. Yes these are the points.  The app trying to get the token every time makes the app very slow to start up. Although we have a custom app, but I also tried with the azure sample and see the same multiple calls to get a token.
Also, the final set of properties is required for all. I had to add (in addition to the docs) subscription-id and resource-group too .

@dhananjay12
For the doc issue,  you can refer to the reference doc.
In the Section below, you can find the following section after the demo snippets:

For the default usage is to provision the resource at the first place.  This is by purpose.
This is the answer for the issue about the configuration for resource provision at the starting.

@dhananjay12
Tried Azure App Service, didn't find the issue of token expiry.
Will try AKS and reply then.
If you think there is something important to sync with me, please do not hesitate to let me know. Thank you.

We are on AKS, as you can see from the 2nd  logs. Its going in some kind of loop during startup. Just posted partial logs and even after the application started it continues to do the same because Consumers keep trying to provision the subscription and does than by fetching the token again and again.

Hi @jialigit
Did you get a chance to check with AKS?

@dhananjay12 sorry for delay. Can I know how you grant the control access to the application? I am not sure if that affects the result. I will check it soon.

@dhananjay12 , Hi, can provide details about how you integrate the managed identity and how to configure the roles?

@jialigit
👋  I work with @dhananjay12
We are using the workload identity project:
https://github.com/Azure/azure-workload-identity
The following is a rough outline although it is geared towards KV as an example:
https://azure.github.io/azure-workload-identity/docs/quick-start.html
We assign the following role:Azure Service Bus Data Owner to the sp

@alexwbb
Sorry for delay. I have to dig more time to dive into it. Will reply as early as possible. Thank you very much.

@hui1110 Please let us know if you require any extra information or input from us,
We are willing to help

Close this issue now, duplicate in https://github.com/Azure/azure-sdk-for-java/issues/30324

@alexwbb Sorry for delay, I responded to this issue: https://github.com/Azure/azure-sdk-for-java/issues/30324 .I try to run in AKS but it fails.

@hui1110 Thanks for your response!
I believe this issue may need to remain open (or be resolved with something other than duplicate) as it's a separate discussion.
https://github.com/Azure/azure-sdk-for-java/issues/30324 is related to auto-creation of topics an issue our developers were seeing. They will update further there 👍
This issue is related to authentication with Azure Workload Identity (see: https://github.com/Azure/azure-sdk-for-java/issues/29032#issuecomment-1147337663) not working with the spring-cloud-azure-stream-binder-servicebus binder,
We see long delays in provisioning topics (up to 4 mins) when using this method of authentication,
If the answer is that currently Workload identity is not supported that's no problem, this may instead be a feature request

Quick update.
Workload identity currently only supports federated credentials with SPNs which doesn't seem to work with the binder,
Judging by:
https://azure.github.io/azure-workload-identity/docs/#limitations
MSI support is coming soon so hopefully no changes will be required your side 👍
Please ignore my comments and leave this issue in closed stat


Rule selector parser

Description
Rule selector parser
Type of change

New feature (non-breaking change which adds functionality)

Testing steps
N/A

Codecov Report

Merging #182 (29d23de) into master (dc4a8ae) will increase coverage by 0.13%.
The diff coverage is 100.00%.

@@            Coverage Diff             @@
##           master     #182      +/-   ##
==========================================
+ Coverage   90.66%   90.80%   +0.13%
==========================================
  Files          20       21       +1
  Lines         793      805      +12
==========================================
+ Hits          719      731      +12
  Misses         62       62
  Partials       12       12

Impacted Files
Coverage Δ

parsers/rule.go
100.00% <100.00%> (ø)

Continue to review full report at Codecov.

Legend - Click here to learn more
Δ = absolute <relative> (impact), ø = not affected, ? = missing data
Powered by Codecov. Last update dc4a8ae...29d23de. Read the comment docs.


Bean reference fields should have an addition button next to it allowing to jump to the entry in the beans tab

Currently Bean Ref fields in the config form are displayed as drop down with the possibility to select an existing bean or creating a new one. Can we show a button on the right of the drop down which allows the following:

if no bean is currently selected, it will just jump to the bean tab
if a bean is currently selected, it will jump to the bean tab and select the corresponding  bean there

I don't know how hard it is but it would be convenient if we offer kind of a "go back" link / button, which allows you to go back to the design tab and be on the same screen you left before.

w/r/t going back to the config form, we can show full beans editor in the modal. I don't know if it's feasible to fully route to the Beans page/tab and put a link to come back to the Design page/tab in exactly same state. @lordrip do you have an idea if it's feasible and if it's worth doing it but not in a modal?
Also see:

https://github.com/KaotoIO/kaoto-next/issues/558#issuecomment-1862804706

That could be also an option, Tomo...using the modal.

w/r/t going back to the config form, we can show full beans editor in the modal. I don't know if it's feasible to fully route to the Beans page/tab and put a link to come back to the Design page/tab in exactly same state. @lordrip do you have an idea if it's feasible and if it's worth doing it but not in a modal?
Also see:
* [Renaming the bean in source code not reflected in the form and bean reference in route source  #558 (comment)](https://github.com/KaotoIO/kaoto-next/issues/558#issuecomment-1862804706)

Yes, it is possible, we just need to rely more on the Router. Now, for this to work in both scenarios, we would need to use the Router also in the VSCode wrapper as well.


Rebootstrap Ammonite on latest Mill master

@lihaoyi You may want to move the release* jobs to separate workflows (so separate .yml files). For now, the GitHub actions UI doesn't allow to re-run individual jobs, if ever one of them fails. You can only re-run whole workflows. That could be a problem if one of the release jobs fails. We would have to re-run even the ones that succeeded, and they would fail too (attempting to release again artifacts that were already published). Whereas if they're in separate workflows, they could be re-run individually.
A drawback of that would be that the release jobs wouldn't wait for the tests to have run fine. But if we only merge green PRs, that shouldn't be a problem.


Add NOTICE file.

@franckcuny you may have seen this already, but just in case you may want to have a look at the instructions here:
http://www.apache.org/dev/licensing-howto.html

The notice file looks good to me. +1.
@fpj did you see any problem here?

@franckcuny @sijie It looks good, but I haven't done an inspection of dependencies and such to determine whether we have anything we need to add to the notice file. That's main reason why I shared the link above.

LGTM +1


[wip] Allow generating historical API versions

It's true we were modifying the release note file of the historical version in the non-historical folder. That's the reason for the changes in release-notes/0.44.md. It should be fixed now, thanks for your comments @Eric-Arellano  :+1:

It's true we were modifying the release note file of the historical version in the non-historical folder. That's the reason for the changes in release-notes/0.44.md. It should be fixed now, thanks for your comments @Eric-Arellano  :+1:


CLOUDSTACK-8215: SAML changing date calculation

Changed to java.util.Calendar which is a bit more straight forward to use.
Tested and verified that the new certificate is valid for 3 years

Just a personal preference: using Joda DateTime might make it more readable :)
DateTime now = DateTime.now(DateTimeZone.UTC);
certGen.setNotBefore(now.minusDays(1).toDate());
certGen.setNotAfter(now.plusYears(3).toDate());

I agree with you :-)
I didn't know we had Joda DateTime available, and with my limited Java experience I didn't want to head out on the journey to introduce it..
I'll rewrite to DateTime and push a new commit

+1 LGTM

Applied on both 4.5 and master. Thanks for fixing this @terbolous !

Off topic but I'm not the Rohit you'll are looking for. :)


Ported to Node

Hi Sean,
Ported your Markov PHP code to Node and added some inline-documentation.
https://github.com/josher19/markov
Could probably be combined with Faker-Phil to generate random websites and fake user data.
Best Regards,
Josh Weinstein

Thanks Josh.  This indeed looks useful to have in the Node.js domain!


[bug]:  negative num_confirmations at onChain transaction

Background
Started lnd + RTL, send sats to lnd onChain.
bitcoin-cli shows that the transaction has 100+ confirmations, lnd shows as negative confirmed lol.
See screenshots below.
Your environment

version of lnd: lnd version 0.15.5-beta commit=v0.15.5-beta
which operating system: Linux coreserver 5.15.84-v7l+  1613 SMP Thu Jan 5 12:01:26 GMT 2023 armv7l GNU/Linux
version of bitcoind: Bitcoin Core version v22.0.0
bitcoin.conf

lnd.conf

similar issue:
https://github.com/lightningnetwork/lnd/issues/7255
Steps to reproduce

Install via git clone & make
Send stats onChain via RTL

Expected behaviour
confirmed transaction shows as unconfirmed
Actual behaviour
transaction should be confirmed

Thank you for your answer.
Now my question is why is my node not synced and how do i fix this?

Is it still not synced? If it was disconnected for a while your node needs to catch up with everything that happens while it was "sleeping".
If it is not synced I would recommend you to check the logs.

Now its synced. I dont expected that the catch up takes so much time.
Thank you very much for your help.